public final class SubscriberHelpers extends Object
| Modifier and Type | Class and Description |
|---|---|
static class |
SubscriberHelpers.ObservableSubscriber<T>
A Subscriber that stores the publishers results and provides a latch so can block on completion.
|
static class |
SubscriberHelpers.OperationSubscriber<T>
A Subscriber that immediately requests Integer.MAX_VALUE onSubscribe
|
static class |
SubscriberHelpers.PrintDocumentSubscriber
A Subscriber that prints the json version of each document
|
static class |
SubscriberHelpers.PrintSubscriber<T>
A Subscriber that prints a message including the received items on completion
|