Package akka.stream.impl.fusing
Class ActorGraphInterpreter.OutputBoundaryPublisher
- java.lang.Object
-
- akka.stream.impl.fusing.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>
-
-
Constructor Summary
Constructors Constructor Description OutputBoundaryPublisher(ActorGraphInterpreter.ActorOutputBoundary boundary, java.lang.String internalPortName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
shutdown(scala.Option<java.lang.Throwable> reason)
void
subscribe(org.reactivestreams.Subscriber<? super java.lang.Object> subscriber)
scala.collection.immutable.Seq<org.reactivestreams.Subscriber<java.lang.Object>>
takePendingSubscribers()
java.lang.String
toString()
protected java.lang.Object
wakeUpMsg()
-
-
-
Constructor Detail
-
OutputBoundaryPublisher
public OutputBoundaryPublisher(ActorGraphInterpreter.ActorOutputBoundary boundary, java.lang.String internalPortName)
-
-
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 interfaceorg.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 classjava.lang.Object
-
wakeUpMsg
protected java.lang.Object wakeUpMsg()
-
-