public class ActorPublisher<T>
extends java.lang.Object
implements org.reactivestreams.Publisher<T>
When you instantiate this class, or its subclasses, you MUST send an ExposedPublisher message to the wrapped ActorRef! If you don't need to subclass, prefer the apply() method on the companion object which takes care of this.
Modifier and Type | Class and Description |
---|---|
static class |
ActorPublisher.NormalShutdownException |
Constructor and Description |
---|
ActorPublisher(ActorRef impl) |
Modifier and Type | Method and Description |
---|---|
static <T> ActorPublisher<T> |
apply(ActorRef impl) |
ActorRef |
impl() |
static java.lang.Throwable |
NormalShutdownReason() |
static java.lang.String |
NormalShutdownReasonMessage() |
void |
shutdown(scala.Option<java.lang.Throwable> reason) |
static scala.Some<java.lang.Throwable> |
SomeNormalShutdownReason() |
void |
subscribe(org.reactivestreams.Subscriber<? super T> subscriber) |
scala.collection.immutable.Seq<org.reactivestreams.Subscriber<? super T>> |
takePendingSubscribers() |
protected java.lang.Object |
wakeUpMsg() |
public ActorPublisher(ActorRef impl)
public static java.lang.String NormalShutdownReasonMessage()
public static java.lang.Throwable NormalShutdownReason()
public static scala.Some<java.lang.Throwable> SomeNormalShutdownReason()
public static <T> ActorPublisher<T> apply(ActorRef impl)
public ActorRef impl()
protected java.lang.Object wakeUpMsg()
public void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
subscribe
in interface org.reactivestreams.Publisher<T>
public scala.collection.immutable.Seq<org.reactivestreams.Subscriber<? super T>> takePendingSubscribers()
public void shutdown(scala.Option<java.lang.Throwable> reason)