public abstract class AbstractActorPublisherWithStash<T> extends AbstractActor implements ActorPublisher<T>, Stash
AbstractActorPublisher
.akka.stream.actor.ActorPublisher} and {@link akka.stream.actor.AbstractActorWithStash}
ActorPublisher.Internal$
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
AbstractActorPublisherWithStash() |
Modifier and Type | Method and Description |
---|---|
DequeBasedMessageQueueSemantics |
mailbox() |
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, emptyBehavior, getContext, postRestart, postStop, preRestart, preStart, receive, receive, self, sender, supervisorStrategy, unhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancelSelf, isActive, isCanceled, isCompleted, isErrorEmitted, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, subscriptionTimeout, totalDemand
postStop, preRestart
context, postRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
actorCell, clearStash, context, enqueueFirst, prepend, self, stash, unstash, unstashAll, unstashAll
public DequeBasedMessageQueueSemantics mailbox()
mailbox
in interface StashSupport