Package | Description |
---|---|
com.github.davidmoten.rx2.buffertofile | |
com.github.davidmoten.rx2.internal.flowable.buffertofile |
Modifier and Type | Class and Description |
---|---|
class |
SerializerString |
Modifier and Type | Method and Description |
---|---|
static Serializer<byte[]> |
Serializers.bytes() |
static <T> Serializer<T> |
Serializers.from(DataSerializer<T> ds) |
static <T extends Serializable> |
Serializers.javaIO() |
static Serializer<String> |
Serializers.string(Charset charset) |
static Serializer<String> |
Serializers.utf8() |
Modifier and Type | Method and Description |
---|---|
<T> io.reactivex.FlowableTransformer<T,T> |
Options.BuilderFlowable.serializer(Serializer<T> serializer) |
<T> io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Flowable<T>> |
Options.BuilderObservable.serializer(Serializer<T> serializer) |
Modifier and Type | Class and Description |
---|---|
class |
SerializerBytes |
class |
SerializerJavaIO<T extends Serializable> |
Constructor and Description |
---|
BufferToFileSubscriberFlowable(org.reactivestreams.Subscriber<? super T> child,
PagedQueue queue,
Serializer<T> serializer,
io.reactivex.Scheduler.Worker worker) |
FlowableOnBackpressureBufferToFile(io.reactivex.Flowable<T> source,
io.reactivex.Observable<T> source2,
Options options,
Serializer<T> serializer) |
Copyright © 2013–2020. All rights reserved.