public abstract class AbstractActorPublisherWithUnrestrictedStash<T> extends AbstractActor implements ActorPublisher<T>, UnrestrictedStash
AbstractActorPublisher
.akka.stream.actor.ActorPublisher} and {@link akka.stream.actor.AbstractActorWithUnrestrictedStash}
ActorPublisher.Internal$
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
AbstractActorPublisherWithUnrestrictedStash() |
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 AbstractActorPublisherWithUnrestrictedStash()
public DequeBasedMessageQueueSemantics mailbox()
mailbox
in interface StashSupport