com.github.davidmoten.rx.operators

Class OperatorFileTailer

java.lang.Object

com.github.davidmoten.rx.operators.OperatorFileTailer

All Implemented Interfaces:

rx.functions.Func1<rx.Subscriber<? super byte[]>,rx.Subscriber<? super Object>>, rx.functions.Function, rx.Observable.Operator<byte[],Object>

public class OperatorFileTailer
extends Object
implements rx.Observable.Operator<byte[],Object>

Reacts to source events by emitting new lines written to a file since the last source event.

Constructor Summary

Constructors

Constructor and Description
OperatorFileTailer(File file, long startPosition) Constructor.
OperatorFileTailer(File file, long startPosition, int maxBytesPerEmission) Constructor.

Method Summary

Modifier and Type	Method and Description
rx.Subscriber<? super Object>	call(rx.Subscriber<? super byte[]> child)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorFileTailer

public OperatorFileTailer(File file,
                          long startPosition,
                          int maxBytesPerEmission)

Constructor.

Parameters:

file - text file to tail

startPosition - start tailing the file after this many bytes

OperatorFileTailer

public OperatorFileTailer(File file,
                          long startPosition)

Constructor. Emits byte arrays of up to 8*1024 bytes.

Parameters:

file -

startPosition -

Method Detail

call

public rx.Subscriber<? super Object> call(rx.Subscriber<? super byte[]> child)

Specified by:

call in interface rx.functions.Func1<rx.Subscriber<? super byte[]>,rx.Subscriber<? super Object>>