Package akka.stream.actor
Interface ActorSubscriber
-
- All Superinterfaces:
Actor
- All Known Implementing Classes:
AbstractActorSubscriber
,ActorRefSinkActor
,FileSubscriber
,OutputStreamSubscriber
,UntypedActorSubscriber
public interface ActorSubscriber extends Actor
Deprecated.Use `akka.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. Since 2.5.0.INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
ActorSubscriber.OnSubscribe
Deprecated.INTERNAL APIstatic class
ActorSubscriber.OnSubscribe$
Deprecated.-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description void
_canceled_$eq(boolean x$1)
Deprecated.void
aroundPostRestart(java.lang.Throwable reason)
Deprecated.INTERNAL APIvoid
aroundPostStop()
Deprecated.INTERNAL APIvoid
aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
Deprecated.INTERNAL APIvoid
aroundPreStart()
Deprecated.INTERNAL APIvoid
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
Deprecated.INTERNAL APIvoid
cancel()
Deprecated.Cancel upstream subscription.boolean
canceled()
Deprecated.int
longToIntMax(long n)
Deprecated.int
remainingRequested()
Deprecated.The number of stream elements that have already been requested from upstream but not yet received.void
request(long elements)
Deprecated.Request a number of elements from upstream.void
requested_$eq(long x$1)
Deprecated.RequestStrategy
requestStrategy()
Deprecated.void
subscription_$eq(scala.Option<org.reactivestreams.Subscription> x$1)
Deprecated.void
super$aroundPostRestart(java.lang.Throwable reason)
Deprecated.INTERNAL APIvoid
super$aroundPostStop()
Deprecated.INTERNAL APIvoid
super$aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
Deprecated.INTERNAL APIvoid
super$aroundPreStart()
Deprecated.INTERNAL APIvoid
super$aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
Deprecated.INTERNAL API-
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
-
-
-
-
Method Detail
-
super$aroundReceive
void super$aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
Deprecated.INTERNAL API- Parameters:
receive
- (undocumented)msg
- (undocumented)
-
super$aroundPreStart
void super$aroundPreStart()
Deprecated.INTERNAL API
-
super$aroundPostRestart
void super$aroundPostRestart(java.lang.Throwable reason)
Deprecated.INTERNAL API- Parameters:
reason
- (undocumented)
-
super$aroundPreRestart
void super$aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
Deprecated.INTERNAL API- Parameters:
reason
- (undocumented)message
- (undocumented)
-
super$aroundPostStop
void super$aroundPostStop()
Deprecated.INTERNAL API
-
subscription_$eq
void subscription_$eq(scala.Option<org.reactivestreams.Subscription> x$1)
Deprecated.
-
requested_$eq
void requested_$eq(long x$1)
Deprecated.
-
_canceled_$eq
void _canceled_$eq(boolean x$1)
Deprecated.
-
requestStrategy
RequestStrategy requestStrategy()
Deprecated.
-
canceled
boolean canceled()
Deprecated.
-
aroundReceive
void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
Deprecated.INTERNAL API- Specified by:
aroundReceive
in interfaceActor
- Parameters:
receive
- (undocumented)msg
- (undocumented)
-
aroundPreStart
void aroundPreStart()
Deprecated.INTERNAL API- Specified by:
aroundPreStart
in interfaceActor
-
aroundPostRestart
void aroundPostRestart(java.lang.Throwable reason)
Deprecated.INTERNAL API- Specified by:
aroundPostRestart
in interfaceActor
- Parameters:
reason
- (undocumented)
-
aroundPreRestart
void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
Deprecated.INTERNAL API- Specified by:
aroundPreRestart
in interfaceActor
- Parameters:
reason
- (undocumented)message
- (undocumented)
-
aroundPostStop
void aroundPostStop()
Deprecated.INTERNAL API- Specified by:
aroundPostStop
in interfaceActor
-
request
void request(long elements)
Deprecated.Request a number of elements from upstream.- Parameters:
elements
- (undocumented)
-
cancel
void cancel()
Deprecated.Cancel upstream subscription. No more elements will be delivered after cancel.The
ActorSubscriber
will be stopped immediately after signaling cancellation. In case the upstream subscription has not yet arrived the Actor will stay alive until a subscription arrives, cancel it and then stop itself.
-
remainingRequested
int remainingRequested()
Deprecated.The number of stream elements that have already been requested from upstream but not yet received.- Returns:
- (undocumented)
-
longToIntMax
int longToIntMax(long n)
Deprecated.
-
-