akka.stream.impl.fusing

Class ActorGraphInterpreter.BoundaryPublisher

java.lang.Object

akka.stream.impl.ActorPublisher<java.lang.Object>

akka.stream.impl.fusing.ActorGraphInterpreter.BoundaryPublisher

All Implemented Interfaces:

org.reactivestreams.Publisher<java.lang.Object>

Enclosing class:

ActorGraphInterpreter

public static final class ActorGraphInterpreter.BoundaryPublisher
extends ActorPublisher<java.lang.Object>

Nested Class Summary

Nested classes/interfaces inherited from class akka.stream.impl.ActorPublisher

ActorPublisher.NormalShutdownException

Constructor Summary

Constructors

Constructor and Description
BoundaryPublisher(ActorRef parent, GraphInterpreterShell shell, int id)

Method Summary

Modifier and Type	Method and Description
ActorGraphInterpreter.SubscribePending	wakeUpMsg()

Methods inherited from class akka.stream.impl.ActorPublisher

apply, impl, NormalShutdownReason, NormalShutdownReasonMessage, shutdown, SomeNormalShutdownReason, subscribe, takePendingSubscribers

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BoundaryPublisher

public BoundaryPublisher(ActorRef parent,
                         GraphInterpreterShell shell,
                         int id)

Method Detail

wakeUpMsg

public ActorGraphInterpreter.SubscribePending wakeUpMsg()

Overrides:

wakeUpMsg in class ActorPublisher<java.lang.Object>