Package org.apache.pekko.stream.testkit

Class TestPublisher.Probe<T>

java.lang.Object

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

org.apache.pekko.stream.testkit.TestPublisher.Probe<T>

All Implemented Interfaces:

org.reactivestreams.Publisher<T>

Enclosing class:

TestPublisher

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

Single subscription and demand tracking for TestPublisher.ManualProbe.

Method Summary

Modifier and Type	Method	Description
void	ensureSubscription()	Asserts that a subscription has been received or will be received
TestPublisher.Probe<T>	expectCancellation()
<E extends Throwable> E	expectCancellationWithCause(Class<E> causeClass)	Java API
TestPublisher.Probe<T>	expectCancellationWithCause(Throwable expectedCause)
<E extends Throwable> E	expectCancellationWithCause(scala.reflect.ClassTag<E> evidence$1)
long	expectRequest()
long	pending()	Current pending requests.
TestPublisher.Probe<T>	sendComplete()
TestPublisher.Probe<T>	sendError(Throwable cause)
TestPublisher.Probe<T>	sendNext(T elem)
TestPublisher.Probe<T>	unsafeSendNext(T elem)

Methods inherited from class org.apache.pekko.stream.testkit.TestPublisher.ManualProbe

executeAfterSubscription, executeAfterSubscription, expectEventPF, expectNoMessage, expectNoMessage, expectNoMessage, expectRequest, expectSubscription, getPublisher, receiveWhile, receiveWhile, receiveWhile$default$1, receiveWhile$default$2, receiveWhile$default$3, subscribe, 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 void ensureSubscription()

Asserts that a subscription has been received or will be received

pending

public long pending()

Current pending requests.

sendNext

public TestPublisher.Probe<T> sendNext(T elem)

unsafeSendNext

public TestPublisher.Probe<T> unsafeSendNext(T elem)

sendComplete

public TestPublisher.Probe<T> sendComplete()

sendError

public TestPublisher.Probe<T> sendError(Throwable cause)

expectRequest

public long expectRequest()

expectCancellation

public TestPublisher.Probe<T> expectCancellation()

expectCancellationWithCause

public TestPublisher.Probe<T> expectCancellationWithCause(Throwable expectedCause)

expectCancellationWithCause

public <E extends Throwable> E expectCancellationWithCause(scala.reflect.ClassTag<E> evidence$1)

expectCancellationWithCause

public <E extends Throwable> E expectCancellationWithCause(Class<E> causeClass)

Java API