com.github.davidmoten.rx2.buffertofile

Class Options.BuilderObservable

java.lang.Object

com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable

Enclosing class:

Options

public static final class Options.BuilderObservable
extends Object

Method Summary

Modifier and Type	Method and Description
Options.BuilderObservable	fileFactory(Callable<File> fileFactory) Sets the file factory to be used by the queue storage mechanism.
Options.BuilderObservable	pageSizeBytes(int pageSizeBytes) Sets the page size in bytes.
Options.BuilderObservable	scheduler(io.reactivex.Scheduler scheduler) Sets the scheduler to use for reading items from files and emitting them.
<T> io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Flowable<T>>	serializer(DataSerializer<T> ds)
<T> io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Flowable<T>>	serializer(Serializer<T> serializer)
io.reactivex.functions.Function<io.reactivex.Observable<byte[]>,io.reactivex.Flowable<byte[]>>	serializerBytes() Returns a Flowable Transformer that buffers items to disk (files).
<T extends Serializable> io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Flowable<T>>	serializerJavaIO() Returns a Flowable Transformer to buffer stream items to disk (files).
io.reactivex.functions.Function<io.reactivex.Observable<String>,io.reactivex.Flowable<String>>	serializerUtf8()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

pageSizeBytes

public Options.BuilderObservable pageSizeBytes(int pageSizeBytes)

Sets the page size in bytes. A page corresponds to a single memory mapped file. If this method is not called the default value is 1MB (1024*1024 bytes).

Parameters:

pageSizeBytes - the page size in bytes.

Returns:

this

scheduler

public Options.BuilderObservable scheduler(io.reactivex.Scheduler scheduler)

Sets the scheduler to use for reading items from files and emitting them.

Parameters:

scheduler - for emitting items

Returns:

this

fileFactory

public Options.BuilderObservable fileFactory(Callable<File> fileFactory)

Sets the file factory to be used by the queue storage mechanism. Defaults to using File.createTempFile("bufferToFileDb","") if this method is not called.

Parameters:

fileFactory - the factory

Returns:

the current builder

serializerJavaIO

public <T extends Serializable> io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Flowable<T>> serializerJavaIO()

Returns a Flowable Transformer to buffer stream items to disk (files). The serialization method uses java.io.ObjectOutputStream for writing values to disk and java.io.ObjectInputStream for reading values from disk and emitting them. Note that this is a pretty verbose serialization method for small items in that a 4 byte Integer is serialized to an 81 byte array!

Type Parameters:

T - stream item type

Returns:

FlowableTransformer using the java io serializer

serializerBytes

public io.reactivex.functions.Function<io.reactivex.Observable<byte[]>,io.reactivex.Flowable<byte[]>> serializerBytes()

Returns a Flowable Transformer that buffers items to disk (files). The serialization method passes through byte arrays directly for both writing and reading.

Returns:

FlowableTransformer using the bytes serializer

serializerUtf8

public io.reactivex.functions.Function<io.reactivex.Observable<String>,io.reactivex.Flowable<String>> serializerUtf8()

serializer

public <T> io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Flowable<T>> serializer(Serializer<T> serializer)

serializer

public <T> io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Flowable<T>> serializer(DataSerializer<T> ds)