Package | Description |
---|---|
com.github.davidmoten.rx2.buffertofile | |
com.github.davidmoten.rx2.flowable |
Modifier and Type | Method and Description |
---|---|
static Options.BuilderFlowable |
Options.builderFlowable() |
Options.BuilderFlowable |
Options.BuilderFlowable.fileFactory(Callable<File> fileFactory)
Sets the file factory to be used by the queue storage mechanism.
|
Options.BuilderFlowable |
Options.BuilderFlowable.pageSizeBytes(int pageSizeBytes)
Sets the page size in bytes.
|
Options.BuilderFlowable |
Options.BuilderFlowable.scheduler(io.reactivex.Scheduler scheduler)
Sets the scheduler to use for reading items from files and emitting
them.
|
Modifier and Type | Method and Description |
---|---|
static Options.BuilderFlowable |
Transformers.onBackpressureBufferToFile() |
Copyright © 2013–2020. All rights reserved.