C F O T 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

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

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

F

FileObservable - Class in com.github.davidmoten.rx

Observable utility methods related to File.

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

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.

O

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

T

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 modify events to an observable that reads and reports new sequences of bytes to a subscriber.

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

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

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 modify events to an observable that reads and reports new lines to a subscriber.

tailTextFile(File, long, 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.

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 F O T W