Package | Description |
---|---|
com.github.davidmoten.rx | |
com.github.davidmoten.rx.buffertofile | |
com.github.davidmoten.rx.internal.operators |
Modifier and Type | Method and Description |
---|---|
static <T> rx.Observable.Transformer<T,T> |
Transformers.onBackpressureBufferToFile(DataSerializer<T> serializer) |
static <T> rx.Observable.Transformer<T,T> |
Transformers.onBackpressureBufferToFile(DataSerializer<T> serializer,
rx.Scheduler scheduler) |
static <T> rx.Observable.Transformer<T,T> |
Transformers.onBackpressureBufferToFile(DataSerializer<T> serializer,
rx.Scheduler scheduler,
Options options) |
Modifier and Type | Method and Description |
---|---|
static DataSerializer<byte[]> |
DataSerializers.byteArray() |
static DataSerializer<Integer> |
DataSerializers.integer() |
static <T> DataSerializer<T> |
DataSerializers.javaIO() |
static DataSerializer<String> |
DataSerializers.string() |
Constructor and Description |
---|
FileBasedSPSCQueueMemoryMapped(rx.functions.Func0<File> factory,
int size,
DataSerializer<T> serializer) |
FileBasedSPSCQueueMemoryMappedReaderWriter(File file,
int fileSize,
DataSerializer<T> serializer) |
OperatorBufferToFile(DataSerializer<T> dataSerializer,
rx.Scheduler scheduler,
Options options) |
Copyright © 2013–2016. All rights reserved.