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()