Package akka.stream.actor
Class AbstractActorPublisherWithUnboundedStash<T>
- java.lang.Object
-
- akka.actor.AbstractActor
-
- akka.stream.actor.AbstractActorPublisherWithUnboundedStash<T>
-
- All Implemented Interfaces:
Actor
,StashSupport
,UnboundedStash
,UnrestrictedStash
,RequiresMessageQueue<UnboundedDequeBasedMessageQueueSemantics>
,ActorPublisher<T>
public abstract class AbstractActorPublisherWithUnboundedStash<T> extends AbstractActor implements ActorPublisher<T>, UnboundedStash
Deprecated.Useakka.stream.stage.GraphStage
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.Java API compatible with lambda expressions. This class adds an unbounded Stash toAbstractActorPublisher
.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.actor.AbstractActor
AbstractActor.ActorContext, AbstractActor.Receive
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
Nested classes/interfaces inherited from interface akka.stream.actor.ActorPublisher
ActorPublisher.Internal$
-
-
Constructor Summary
Constructors Constructor Description AbstractActorPublisherWithUnboundedStash()
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected void
akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
Deprecated.DequeBasedMessageQueueSemantics
mailbox()
Deprecated.-
Methods inherited from class akka.actor.AbstractActor
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, createReceive, emptyBehavior, getContext, getSelf, getSender, postRestart, postStop, preRestart, preRestart, preStart, receive, receiveBuilder, self, supervisorStrategy
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.stream.actor.ActorPublisher
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancelSelf, demand_$eq, isActive, isCanceled, isCompleted, isErrorEmitted, lifecycleState_$eq, onComplete, onCompleteThenStop, onError, onErrorThenStop, onNext, scheduledSubscriptionTimeout_$eq, subscriber_$eq, subscriptionTimeout, super$aroundPostRestart, super$aroundPostStop, super$aroundPreRestart, super$aroundPreStart, super$aroundReceive, totalDemand
-
Methods inherited from interface akka.actor.StashSupport
actorCell, clearStash, context, enqueueFirst, prepend, self, stash, theStash_$eq, unstash, unstashAll, unstashAll
-
Methods inherited from interface akka.actor.UnrestrictedStash
postStop, preRestart, super$postStop, super$preRestart
-
-
-
-
Method Detail
-
akka$actor$StashSupport$_setter_$mailbox_$eq
protected void akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
Deprecated.- Specified by:
akka$actor$StashSupport$_setter_$mailbox_$eq
in interfaceStashSupport
-
mailbox
public DequeBasedMessageQueueSemantics mailbox()
Deprecated.- Specified by:
mailbox
in interfaceStashSupport
-
-