com.github.davidmoten.rx2.file

Class Files.TailBytesUsingCustomEventsBuilder

java.lang.Object

com.github.davidmoten.rx2.file.Files.TailBytesUsingCustomEventsBuilder

Enclosing class:

Files

public static final class Files.TailBytesUsingCustomEventsBuilder
extends Object

Constructor Summary

Constructors

Constructor and Description
TailBytesUsingCustomEventsBuilder(File file, io.reactivex.Observable<WatchEvent<?>> events)

Method Summary

Modifier and Type	Method and Description
Files.TailBytesUsingCustomEventsBuilder	backpressureStrategy(io.reactivex.BackpressureStrategy backpressureStrategy)
io.reactivex.Flowable<byte[]>	build()
Files.TailBytesUsingCustomEventsBuilder	chunkSize(int chunkSize) Emissions from the tailed file will be no bigger than this.
Files.TailBytesUsingCustomEventsBuilder	modifier(WatchEvent.Modifier modifier)
Files.TailBytesUsingCustomEventsBuilder	sampleInterval(long duration, TimeUnit unit)
Files.TailBytesUsingCustomEventsBuilder	startPosition(long startPosition) The startPosition in bytes in the file to commence the tail from.

Methods inherited from class java.lang.Object

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

Constructor Detail

TailBytesUsingCustomEventsBuilder

public TailBytesUsingCustomEventsBuilder(File file,
                                         io.reactivex.Observable<WatchEvent<?>> events)

Method Detail

startPosition

public Files.TailBytesUsingCustomEventsBuilder startPosition(long startPosition)

The startPosition in bytes in the file to commence the tail from. 0 = start of file. Defaults to 0.

Parameters:

startPosition - start position

Returns:

this

chunkSize

public Files.TailBytesUsingCustomEventsBuilder chunkSize(int chunkSize)

Emissions from the tailed file will be no bigger than this.

Parameters:

chunkSize - chunk size in bytes

Returns:

this

modifier

public Files.TailBytesUsingCustomEventsBuilder modifier(WatchEvent.Modifier modifier)

sampleInterval

public Files.TailBytesUsingCustomEventsBuilder sampleInterval(long duration,
                                                              TimeUnit unit)

backpressureStrategy

public Files.TailBytesUsingCustomEventsBuilder backpressureStrategy(io.reactivex.BackpressureStrategy backpressureStrategy)

build

public io.reactivex.Flowable<byte[]> build()