public final class Bytes extends Object
| Modifier and Type | Method and Description |
|---|---|
static io.reactivex.functions.Function<io.reactivex.Flowable<byte[]>,io.reactivex.Single<byte[]>> |
collect() |
static io.reactivex.Single<byte[]> |
collect(io.reactivex.Flowable<byte[]> source) |
static io.reactivex.Flowable<byte[]> |
from(File file) |
static io.reactivex.Flowable<byte[]> |
from(File file,
int size) |
static io.reactivex.Flowable<byte[]> |
from(InputStream is)
Returns a Flowable stream of byte arrays from the given
InputStream of 8192 bytes. |
static io.reactivex.Flowable<byte[]> |
from(InputStream is,
int bufferSize)
Returns a Flowable stream of byte arrays from the given
InputStream between 1 and bufferSize bytes. |
static io.reactivex.Flowable<ZippedEntry> |
unzip(File file) |
static io.reactivex.Flowable<ZippedEntry> |
unzip(InputStream is) |
static io.reactivex.Flowable<ZippedEntry> |
unzip(ZipInputStream zis) |
public static io.reactivex.Flowable<byte[]> from(InputStream is, int bufferSize)
InputStream between 1 and bufferSize bytes.is - input stream of bytesbufferSize - max emitted byte array sizepublic static io.reactivex.Flowable<byte[]> from(File file)
public static io.reactivex.Flowable<byte[]> from(File file, int size)
public static io.reactivex.Flowable<byte[]> from(InputStream is)
InputStream of 8192 bytes. The final byte array may be
less than 8192 bytes.is - input stream of bytespublic static io.reactivex.Flowable<ZippedEntry> unzip(File file)
public static io.reactivex.Flowable<ZippedEntry> unzip(InputStream is)
public static io.reactivex.Flowable<ZippedEntry> unzip(ZipInputStream zis)
public static io.reactivex.Single<byte[]> collect(io.reactivex.Flowable<byte[]> source)
public static io.reactivex.functions.Function<io.reactivex.Flowable<byte[]>,io.reactivex.Single<byte[]>> collect()
Copyright © 2013–2020. All rights reserved.