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