public static class TestSubscriber.Probe<T> extends TestSubscriber.ManualProbe<T>
TestSubscriber.ManualProbe
.Constructor and Description |
---|
Probe(ActorSystem system) |
Modifier and Type | Method and Description |
---|---|
TestSubscriber.Probe<T> |
cancel() |
TestSubscriber.Probe<T> |
ensureSubscription()
Asserts that a subscription has been received or will be received
|
TestSubscriber.Probe<T> |
request(long n) |
T |
requestNext()
Request and expect a stream element.
|
T |
requestNext(scala.concurrent.duration.FiniteDuration d)
Request and expect a stream element during the specified time or timeout.
|
TestSubscriber.Probe<T> |
requestNext(T element)
Request and expect a stream element.
|
expectComplete, expectError, expectError, expectEvent, expectEvent, expectEvent, expectEventPF, expectNext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNextChainingPF, expectNextN, expectNextN, expectNextOrComplete, expectNextOrComplete, expectNextOrError, expectNextOrError, expectNextPF, expectNextUnordered, expectNextUnordered, expectNextUnorderedN, expectNoMsg, expectNoMsg, expectSubscription, expectSubscriptionAndComplete, expectSubscriptionAndComplete, expectSubscriptionAndError, expectSubscriptionAndError, expectSubscriptionAndError, expectSubscriptionAndError, onComplete, onError, onNext, onSubscribe, receiveWhile, receiveWithin, toStrict, within, within
public Probe(ActorSystem system)
public TestSubscriber.Probe<T> ensureSubscription()
public TestSubscriber.Probe<T> request(long n)
public TestSubscriber.Probe<T> requestNext(T element)
element
- (undocumented)public TestSubscriber.Probe<T> cancel()
public T requestNext()
public T requestNext(scala.concurrent.duration.FiniteDuration d)
d
- (undocumented)