Package akka.stream.actor
Class AbstractActorSubscriber
- java.lang.Object
-
- akka.actor.AbstractActor
-
- akka.stream.actor.AbstractActorSubscriber
-
- All Implemented Interfaces:
Actor
,ActorSubscriber
public abstract class AbstractActorSubscriber extends AbstractActor implements ActorSubscriber
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- See Also:
ActorSubscriber
-
-
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.ActorSubscriber
ActorSubscriber.OnSubscribe, ActorSubscriber.OnSubscribe$
-
-
Constructor Summary
Constructors Constructor Description AbstractActorSubscriber()
Deprecated.
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static <T> org.reactivestreams.Subscriber<T>
create(ActorRef ref)
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, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.stream.actor.ActorSubscriber
_canceled_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancel, canceled, longToIntMax, remainingRequested, request, requested_$eq, requestStrategy, subscription_$eq, super$aroundPostRestart, super$aroundPostStop, super$aroundPreRestart, super$aroundPreStart, super$aroundReceive
-
-
-
-
Method Detail
-
create
public static <T> org.reactivestreams.Subscriber<T> create(ActorRef ref)
Deprecated.
-
-