Class ActorGraphInterpreter.OutputBoundaryPublisher

  • All Implemented Interfaces:
    org.reactivestreams.Publisher<java.lang.Object>
    Enclosing class:
    ActorGraphInterpreter

    public static class ActorGraphInterpreter.OutputBoundaryPublisher
    extends java.lang.Object
    implements org.reactivestreams.Publisher<java.lang.Object>
    • Method Detail

      • shutdown

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

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

        public scala.collection.immutable.Seq<org.reactivestreams.Subscriber<java.lang.Object>> takePendingSubscribers()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • wakeUpMsg

        protected java.lang.Object wakeUpMsg()