Package akka.stream.testkit

Class TestPublisher.Probe<T>

java.lang.Object

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

akka.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 java.lang.Throwable> E	expectCancellationWithCause(java.lang.Class<E> causeClass)	Java API
TestPublisher.Probe<T>	expectCancellationWithCause(java.lang.Throwable expectedCause)
<E extends java.lang.Throwable> E	expectCancellationWithCause(scala.reflect.ClassTag<E> evidence$1)
long	expectRequest()
long	pending()	Current pending requests.
TestPublisher.Probe<T>	sendComplete()
TestPublisher.Probe<T>	sendError(java.lang.Throwable cause)
TestPublisher.Probe<T>	sendNext(T elem)
TestPublisher.Probe<T>	unsafeSendNext(T elem)

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

executeAfterSubscription, expectEventPF, expectNoMessage, expectNoMessage, expectRequest, expectSubscription, getPublisher, receiveWhile, receiveWhile$default$1, receiveWhile$default$2, receiveWhile$default$3, subscribe, within, within

Methods inherited from class java.lang.Object

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

Method Detail

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(java.lang.Throwable cause)

expectRequest

public long expectRequest()

expectCancellation

public TestPublisher.Probe<T> expectCancellation()

expectCancellationWithCause

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

expectCancellationWithCause

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

expectCancellationWithCause

public <E extends java.lang.Throwable> E expectCancellationWithCause(java.lang.Class<E> causeClass)

Java API