public class ActorSubscription<T>
extends java.lang.Object
implements org.reactivestreams.Subscription
Constructor and Description |
---|
ActorSubscription(ActorRef impl,
org.reactivestreams.Subscriber<? super T> subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
ActorRef |
impl() |
void |
request(long elements) |
org.reactivestreams.Subscriber<? super T> |
subscriber() |
public final ActorRef impl()
public final org.reactivestreams.Subscriber<? super T> subscriber()
public void request(long elements)
request
in interface org.reactivestreams.Subscription
public void cancel()
cancel
in interface org.reactivestreams.Subscription