com.github.davidmoten.rx.buffertofile

Class Options.Builder

java.lang.Object

com.github.davidmoten.rx.buffertofile.Options.Builder

Enclosing class:

Options

public static class Options.Builder
extends Object

Method Summary

Modifier and Type	Method and Description
Options	build()
Options.Builder	cacheSizeItems(int cacheSizeItems)
Options.Builder	cacheType(CacheType cacheType) Sets the cache type used by the queue storage mechanism.
Options.Builder	delayError(boolean delayError) Sets if errors are delayed or not when detected.
Options.Builder	fileFactory(rx.functions.Func0<File> fileFactory) Sets the file factory to be used by the queue storage mechanism.
Options.Builder	storageSizeLimitMB(double storageSizeLimitMB)

Methods inherited from class java.lang.Object

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

Method Detail

fileFactory

public Options.Builder fileFactory(rx.functions.Func0<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. MapDB for instance creates two files, one without extension and the other a .p file.

Parameters:

fileFactory - the factory

Returns:

the current builder

cacheType

public Options.Builder cacheType(CacheType cacheType)

Sets the cache type used by the queue storage mechanism. Defaults to CacheType.NO_CACHE if this method is not called.

Parameters:

cacheType - the type of cache

Returns:

the current builder

cacheSizeItems

public Options.Builder cacheSizeItems(int cacheSizeItems)

storageSizeLimitMB

public Options.Builder storageSizeLimitMB(double storageSizeLimitMB)

delayError

public Options.Builder delayError(boolean delayError)

Sets if errors are delayed or not when detected. Defaults to false if this method not called.

Parameters:

delayError - if true errors do not shortcut the queue.

Returns:

the current builder

build

public Options build()