com.github.davidmoten.rx

Class Bytes

java.lang.Object

com.github.davidmoten.rx.Bytes

public final class Bytes
extends Object

Method Summary

Modifier and Type	Method and Description
static rx.Observable.Transformer<byte[],byte[]>	collect()
static rx.Observable<byte[]>	from(File file)
static rx.Observable<byte[]>	from(File file, int size)
static rx.Observable<byte[]>	from(InputStream is) Returns an Observable stream of byte arrays from the given InputStream of 8192 bytes.
static rx.Observable<byte[]>	from(InputStream is, int size) Returns an Observable stream of byte arrays from the given InputStream between 1 and size bytes.
static rx.Observable<ZippedEntry>	unzip(File file)
static rx.Observable<ZippedEntry>	unzip(InputStream is)
static rx.Observable<ZippedEntry>	unzip(ZipInputStream zis)

Methods inherited from class java.lang.Object

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

Method Detail

from

public static rx.Observable<byte[]> from(InputStream is,
                                         int size)

Returns an Observable stream of byte arrays from the given InputStream between 1 and size bytes.

Parameters:

is - input stream of bytes

size - max emitted byte array size

Returns:

a stream of byte arrays

from

public static rx.Observable<byte[]> from(File file)

from

public static rx.Observable<byte[]> from(File file,
                                         int size)

from

public static rx.Observable<byte[]> from(InputStream is)

Returns an Observable stream of byte arrays from the given InputStream of 8192 bytes. The final byte array may be less than 8192 bytes.

Parameters:

is - input stream of bytes

Returns:

a stream of byte arrays

unzip

public static rx.Observable<ZippedEntry> unzip(File file)

unzip

public static rx.Observable<ZippedEntry> unzip(InputStream is)

unzip

public static rx.Observable<ZippedEntry> unzip(ZipInputStream zis)

collect

public static rx.Observable.Transformer<byte[],byte[]> collect()