public final class SubscriberHelpers extends Object
Modifier and Type | Method and Description |
---|---|
static rx.observers.TestSubscriber<org.bson.Document> |
printDocumentSubscriber()
A Subscriber that prints the json version of each document
|
static <T> rx.observers.TestSubscriber<T> |
printSubscriber()
A Subscriber that prints each result onNext
|
static <T> rx.observers.TestSubscriber<T> |
printSubscriber(String onStartMessage)
A Subscriber that prints each result onNext
|
public static <T> rx.observers.TestSubscriber<T> printSubscriber()
T
- The TestSubscriber result typepublic static <T> rx.observers.TestSubscriber<T> printSubscriber(String onStartMessage)
T
- The TestSubscriber result typeonStartMessage
- the initial start message printed on return of the first item.public static rx.observers.TestSubscriber<org.bson.Document> printDocumentSubscriber()