C D F O S T U W

C

call(Subscriber<? super byte[]>) - Method in class com.github.davidmoten.rx.operators.OperatorFileTailer

call(Subscriber<? super WatchEvent<?>>) - Method in class com.github.davidmoten.rx.operators.OperatorWatchServiceEvents

charset(Charset) - Method in class com.github.davidmoten.rx.FileObservable.Builder

The charset of the file.

charset(String) - Method in class com.github.davidmoten.rx.FileObservable.Builder

The charset of the file.

chunkSize(int) - Method in class com.github.davidmoten.rx.FileObservable.Builder

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

com.github.davidmoten.rx - package com.github.davidmoten.rx

com.github.davidmoten.rx.operators - package com.github.davidmoten.rx.operators

D

DEFAULT_MAX_BYTES_PER_EMISSION - Static variable in class com.github.davidmoten.rx.FileObservable

F

file(File) - Method in class com.github.davidmoten.rx.FileObservable.Builder

The file to tail.

file(String) - Method in class com.github.davidmoten.rx.FileObservable.Builder

FileObservable - Class in com.github.davidmoten.rx

Observable utility methods related to File.

FileObservable() - Constructor for class com.github.davidmoten.rx.FileObservable

FileObservable.Builder - Class in com.github.davidmoten.rx

from(WatchService) - Static method in class com.github.davidmoten.rx.FileObservable

Returns an Observable of WatchEvents from a WatchService.

from(File, WatchEvent.Kind<?>...) - Static method in class com.github.davidmoten.rx.FileObservable

If file does not exist at subscribe time then is assumed to not be a directory.

from(File, Action0, WatchEvent.Kind<?>...) - Static method in class com.github.davidmoten.rx.FileObservable

If file does not exist at subscribe time then is assumed to not be a directory.

O

onWatchStarted(Action0) - Method in class com.github.davidmoten.rx.FileObservable.Builder

OperatorFileTailer - Class in com.github.davidmoten.rx.operators

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

OperatorFileTailer(File, long, int) - Constructor for class com.github.davidmoten.rx.operators.OperatorFileTailer

Constructor.

OperatorFileTailer(File, long) - Constructor for class com.github.davidmoten.rx.operators.OperatorFileTailer

Constructor.

OperatorWatchServiceEvents - Class in com.github.davidmoten.rx.operators

Emits WatchEvents for each input WatchService.

OperatorWatchServiceEvents() - Constructor for class com.github.davidmoten.rx.operators.OperatorWatchServiceEvents

S

sampleTimeMs(long) - Method in class com.github.davidmoten.rx.FileObservable.Builder

Specifies sampling to apply to the source observable (which could be very busy if a lot of writes are occurring for example).

source(Observable<?>) - Method in class com.github.davidmoten.rx.FileObservable.Builder

startPosition(long) - Method in class com.github.davidmoten.rx.FileObservable.Builder

The startPosition in bytes in the file to commence the tail from.

T

tail() - Method in class com.github.davidmoten.rx.FileObservable.Builder

tailer() - Static method in class com.github.davidmoten.rx.FileObservable

tailFile(File, long, long, int) - Static method in class com.github.davidmoten.rx.FileObservable

Returns an Observable that uses NIO WatchService (and a dedicated thread) to push modified events to an observable that reads and reports new sequences of bytes to a subscriber.

tailFile(File, long, long, int, Observable<?>) - Static method in class com.github.davidmoten.rx.FileObservable

Returns an Observable that uses given given observable to push modified events to an observable that reads and reports new sequences of bytes to a subscriber.

tailText() - Method in class com.github.davidmoten.rx.FileObservable.Builder

tailTextFile(File, long, long, Charset) - Static method in class com.github.davidmoten.rx.FileObservable

Returns an Observable that uses NIO WatchService (and a dedicated thread) to push modified events to an observable that reads and reports new lines to a subscriber.

tailTextFile(File, long, int, Charset, Observable<?>) - Static method in class com.github.davidmoten.rx.FileObservable

Returns an Observable of String that uses the given events stream to trigger checks on file change so that new lines can be read and emitted.

U

utf8() - Method in class com.github.davidmoten.rx.FileObservable.Builder

W

watchService(File, WatchEvent.Kind<?>...) - Static method in class com.github.davidmoten.rx.FileObservable

Creates a WatchService on subscribe for the given file and event kinds.

C D F O S T U W