Class ActorPublisher<T>

  • All Implemented Interfaces:
    Direct Known Subclasses:

    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.

    • Constructor Detail

      • ActorPublisher

        public ActorPublisher​(ActorRef impl)
    • Method Detail

      • NormalShutdownReasonMessage

        public static java.lang.String NormalShutdownReasonMessage()
      • NormalShutdownReason

        public static java.lang.Throwable NormalShutdownReason()
      • SomeNormalShutdownReason

        public static scala.Some<java.lang.Throwable> SomeNormalShutdownReason()
      • wakeUpMsg

        protected java.lang.Object wakeUpMsg()
      • subscribe

        public void subscribe​(org.reactivestreams.Subscriber<? super T> subscriber)
        Specified by:
        subscribe in interface org.reactivestreams.Publisher<T>
      • takePendingSubscribers

        public scala.collection.immutable.Seq<org.reactivestreams.Subscriber<? super T>> takePendingSubscribers()
      • shutdown

        public void shutdown​(scala.Option<java.lang.Throwable> reason)