akka.stream.testkit

Class StreamTestKit.PublisherProbeSubscription<I>

java.lang.Object

akka.stream.testkit.StreamTestKit.PublisherProbeSubscription<I>

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscription, scala.Equals, scala.Product

Enclosing class:

StreamTestKit

public static final class StreamTestKit.PublisherProbeSubscription<I>
extends java.lang.Object
implements org.reactivestreams.Subscription, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PublisherProbeSubscription(org.reactivestreams.Subscriber<? super I> subscriber, TestProbe publisherProbe)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	expectCancellation()
long	expectRequest()
void	expectRequest(long n)
TestProbe	publisherProbe()
void	request(long elements)
void	sendComplete()
void	sendError(java.lang.Exception cause)
void	sendNext(I element)
void	sendOnSubscribe()
org.reactivestreams.Subscriber<? super I>	subscriber()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

PublisherProbeSubscription

public PublisherProbeSubscription(org.reactivestreams.Subscriber<? super I> subscriber,
                                  TestProbe publisherProbe)

Method Detail

subscriber

public org.reactivestreams.Subscriber<? super I> subscriber()

publisherProbe

public TestProbe publisherProbe()

request

public void request(long elements)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

expectRequest

public void expectRequest(long n)

expectRequest

public long expectRequest()

expectCancellation

public void expectCancellation()

sendNext

public void sendNext(I element)

sendComplete

public void sendComplete()

sendError

public void sendError(java.lang.Exception cause)

sendOnSubscribe

public void sendOnSubscribe()