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.

Constructor Summary

Constructors

Constructor and Description
Probe(long initialPendingRequests, ActorSystem system)

Method Summary

Modifier and Type	Method and Description
void	ensureSubscription() Asserts that a subscription has been received or will be received
TestPublisher.Probe<T>	expectCancellation()
long	expectRequest()
long	pending() Current pending requests.
TestPublisher.Probe<T>	sendComplete()
TestPublisher.Probe<T>	sendError(java.lang.Exception cause)
TestPublisher.Probe<T>	sendNext(T elem)
TestPublisher.Probe<T>	unsafeSendNext(T elem)

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

expectEventPF, expectNoMsg, expectNoMsg, expectRequest, expectSubscription, getPublisher, receiveWhile, subscribe, 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(long initialPendingRequests,
             ActorSystem system)

Method Detail

ensureSubscription

public void ensureSubscription()

Asserts that a subscription has been received or will be received

pending

public long pending()

Current pending requests.

Returns:

(undocumented)

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.Exception cause)

expectRequest

public long expectRequest()

expectCancellation

public TestPublisher.Probe<T> expectCancellation()