public static final class StreamTestKit.FailedSubscription<T>
extends java.lang.Object
implements org.reactivestreams.Subscription, scala.Product, scala.Serializable
Constructor and Description |
---|
FailedSubscription(org.reactivestreams.Subscriber<T> subscriber,
java.lang.Throwable cause) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
java.lang.Throwable |
cause() |
void |
request(long elements) |
org.reactivestreams.Subscriber<T> |
subscriber() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public FailedSubscription(org.reactivestreams.Subscriber<T> subscriber, java.lang.Throwable cause)
public org.reactivestreams.Subscriber<T> subscriber()
public java.lang.Throwable cause()
public void request(long elements)
request
in interface org.reactivestreams.Subscription
public void cancel()
cancel
in interface org.reactivestreams.Subscription