public static final class StreamTestKit.PublisherProbeSubscription<I>
extends java.lang.Object
implements org.reactivestreams.Subscription, scala.Product, scala.Serializable
Constructor and Description |
---|
PublisherProbeSubscription(org.reactivestreams.Subscriber<? super I> subscriber,
TestProbe publisherProbe) |
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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public org.reactivestreams.Subscriber<? super I> subscriber()
public TestProbe publisherProbe()
public void request(long elements)
request
in interface org.reactivestreams.Subscription
public void cancel()
cancel
in interface org.reactivestreams.Subscription
public void expectRequest(long n)
public long expectRequest()
public void expectCancellation()
public void sendNext(I element)
public void sendComplete()
public void sendError(java.lang.Exception cause)
public void sendOnSubscribe()