Package 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.

Method Summary

Modifier and Type	Method	Description
TestSubscriber.Probe<T>	cancel()
TestSubscriber.Probe<T>	cancel(java.lang.Throwable cause)
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, expectEventWithTimeoutPF, expectNext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNextChainingPF, expectNextChainingPF, expectNextN, expectNextN, expectNextOrComplete, expectNextOrComplete, expectNextOrError, expectNextOrError, expectNextPF, expectNextUnordered, expectNextUnordered, expectNextUnorderedN, expectNextWithTimeoutPF, expectNoMessage, expectNoMessage, expectNoMessage, expectSubscription, expectSubscriptionAndComplete, expectSubscriptionAndComplete, expectSubscriptionAndError, expectSubscriptionAndError, expectSubscriptionAndError, expectSubscriptionAndError, onComplete, onError, onNext, onSubscribe, receiveWhile, receiveWhile$default$1, receiveWhile$default$2, receiveWhile$default$3, receiveWithin, receiveWithin$default$2, toStrict, within, within

Methods inherited from class java.lang.Object

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

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.

cancel

public TestSubscriber.Probe<T> cancel()

cancel

public TestSubscriber.Probe<T> cancel(java.lang.Throwable cause)

requestNext

public T requestNext()

Request and expect a stream element.

requestNext

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

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