akka.stream.actor

Class AbstractActorPublisherWithStash<T>

java.lang.Object

akka.actor.AbstractActor

akka.stream.actor.AbstractActorPublisherWithStash<T>

All Implemented Interfaces:

Actor, Stash, StashSupport, UnrestrictedStash, RequiresMessageQueue<DequeBasedMessageQueueSemantics>, ActorPublisher<T>

public abstract class AbstractActorPublisherWithStash<T>
extends AbstractActor
implements ActorPublisher<T>, Stash

Java API compatible with lambda expressions. This class adds a Stash to AbstractActorPublisher.

See Also:

akka.stream.actor.ActorPublisher} and {@link akka.stream.actor.AbstractActorWithStash}

Nested Class Summary

Nested classes/interfaces inherited from interface akka.stream.actor.ActorPublisher

ActorPublisher.Internal$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
AbstractActorPublisherWithStash()

Method Summary

Modifier and Type	Method and Description
DequeBasedMessageQueueSemantics	mailbox()

Methods inherited from class akka.actor.AbstractActor

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.actor.ActorPublisher

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancelSelf, isActive, isCanceled, isCompleted, isErrorEmitted, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, subscriptionTimeout, totalDemand

Methods inherited from interface akka.actor.UnrestrictedStash

postStop, preRestart

Methods inherited from interface akka.actor.Actor

context, postRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.StashSupport

actorCell, clearStash, context, enqueueFirst, prepend, self, stash, unstash, unstashAll, unstashAll

Constructor Detail

AbstractActorPublisherWithStash

public AbstractActorPublisherWithStash()

Method Detail

mailbox

public DequeBasedMessageQueueSemantics mailbox()

Specified by:

mailbox in interface StashSupport