akka.stream.testkit

Class TestSubscriber.Probe<T>

java.lang.Object

akka.stream.testkit.TestSubscriber.ManualProbe<T>

akka.stream.testkit.TestSubscriber.Probe<T>

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

Enclosing class:

TestSubscriber

public static class TestSubscriber.Probe<T>
extends TestSubscriber.ManualProbe<T>

Single subscription tracking for TestSubscriber.ManualProbe.

Constructor Summary

Constructors

Constructor and Description
Probe(ActorSystem system)

Method Summary

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.

Methods inherited from class akka.stream.testkit.TestSubscriber.ManualProbe

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Probe

public Probe(ActorSystem system)

Method Detail

ensureSubscription

public TestSubscriber.Probe<T> ensureSubscription()

Asserts that a subscription has been received or will be received

request

public TestSubscriber.Probe<T> request(long n)

requestNext

public TestSubscriber.Probe<T> requestNext(T element)

Request and expect a stream element.

Parameters:

element - (undocumented)

Returns:

(undocumented)

cancel

public TestSubscriber.Probe<T> cancel()

requestNext

public T requestNext()

Request and expect a stream element.

Returns:

(undocumented)

requestNext

public T requestNext(scala.concurrent.duration.FiniteDuration d)

Request and expect a stream element during the specified time or timeout.

Parameters:

d - (undocumented)

Returns:

(undocumented)