org.davidmoten.rx2.io.internal

Class Util

java.lang.Object

org.davidmoten.rx2.io.internal.Util

public final class Util
extends Object

Method Summary

Modifier and Type	Method and Description
static void	close(Closeable c)
static io.reactivex.functions.BiConsumer<OutputStream,ByteBuffer>	defaultWriter()
static void	readFully(InputStream in, byte[] b, int off, int len)
static int	readInt(InputStream in)
static long	readLong(InputStream in)
static byte[]	toBytes(ByteBuffer bb)
static byte[]	toBytes(int v)
static byte[]	toBytes(long v)
static long	toLong(byte[] b)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

defaultWriter

public static io.reactivex.functions.BiConsumer<OutputStream,ByteBuffer> defaultWriter()

toLong

public static long toLong(byte[] b)

toBytes

public static byte[] toBytes(long v)

toBytes

public static byte[] toBytes(int v)
                      throws IOException

Throws:

IOException

close

public static void close(Closeable c)

readFully

public static void readFully(InputStream in,
                             byte[] b,
                             int off,
                             int len)
                      throws IOException

Throws:

IOException

readLong

public static long readLong(InputStream in)
                     throws IOException

Throws:

IOException

readInt

public static int readInt(InputStream in)
                   throws IOException

Throws:

IOException

toBytes

public static byte[] toBytes(ByteBuffer bb)