Package | Description |
---|---|
com.github.davidmoten.rx2.buffertofile | |
com.github.davidmoten.rx2.observable |
Modifier and Type | Method and Description |
---|---|
static Options.BuilderObservable |
Options.builderObservable() |
Options.BuilderObservable |
Options.BuilderObservable.fileFactory(Callable<File> fileFactory)
Sets the file factory to be used by the queue storage mechanism.
|
Options.BuilderObservable |
Options.BuilderObservable.pageSizeBytes(int pageSizeBytes)
Sets the page size in bytes.
|
Options.BuilderObservable |
Options.BuilderObservable.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.BuilderObservable |
Transformers.onBackpressureBufferToFile() |
Copyright © 2013–2020. All rights reserved.