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>

Constructor Summary

Constructors

Constructor	Description
Probe(long initialPendingRequests, ActorSystem system)

Method Summary

Modifier and Type	Method	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.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, expectNoMsg, expectNoMsg, 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

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

expectCancellation

public TestPublisher.Probe<T> expectCancellation()

expectRequest

public long expectRequest()

pending

public long pending()

Current pending requests.

Returns:

(undocumented)

sendComplete

public TestPublisher.Probe<T> sendComplete()

sendError

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

sendNext

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

unsafeSendNext

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