Package org.apache.pekko.stream.testkit

Class TestSubscriber.Probe<T>

java.lang.Object

org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<T>

org.apache.pekko.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(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(Duration d)	JAVA API
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 org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe

expectComplete, expectError, expectError, expectEvent, expectEvent, expectEvent, expectEvent, expectEventPF, expectEventWithTimeoutPF, expectEventWithTimeoutPF, expectNext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNextChainingPF, expectNextChainingPF, expectNextChainingPF, expectNextN, expectNextN, expectNextN, expectNextOrComplete, expectNextOrComplete, expectNextOrError, expectNextOrError, expectNextPF, expectNextUnordered, expectNextUnordered, expectNextUnorderedN, expectNextUnorderedN, expectNextWithTimeoutPF, expectNextWithTimeoutPF, expectNoMessage, expectNoMessage, expectNoMessage, expectSubscription, expectSubscriptionAndComplete, expectSubscriptionAndComplete, expectSubscriptionAndError, expectSubscriptionAndError, expectSubscriptionAndError, expectSubscriptionAndError, onComplete, onError, onNext, onSubscribe, receiveWhile, receiveWhile, receiveWhile$default$1, receiveWhile$default$2, receiveWhile$default$3, receiveWithin, receiveWithin, receiveWithin$default$2, toStrict, toStrict, within, within, within, within

Methods inherited from class java.lang.Object

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

Method Details

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

requestNext

public T requestNext(Duration d)

JAVA API

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

Since:

1.1.0