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.Builder	bufferSizeBytes(int bufferSizeBytes)
Options	build()
Options.Builder	delayError(boolean delayError) Sets if errors are delayed or not when detected.
Options.Builder	disableRollover()
Options.Builder	fileFactory(rx.functions.Func0<File> fileFactory) Sets the file factory to be used by the queue storage mechanism.
Options.Builder	rolloverEvery(long rolloverEvery)
Options.Builder	rolloverSizeBytes(long rolloverSizeBytes)
Options.Builder	rolloverSizeMB(double rolloverSizeMB)

Methods inherited from class java.lang.Object

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

Method Detail

rolloverSizeMB

public Options.Builder rolloverSizeMB(double rolloverSizeMB)

rolloverSizeBytes

public Options.Builder rolloverSizeBytes(long rolloverSizeBytes)

disableRollover

public Options.Builder disableRollover()

bufferSizeBytes

public Options.Builder bufferSizeBytes(int bufferSizeBytes)

rolloverEvery

public Options.Builder rolloverEvery(long rolloverEvery)

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.

Parameters:

fileFactory - the factory

Returns:

the current builder

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()