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 API
static class	ActorSubscriber.OnSubscribe$	Deprecated.

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Method Summary

Modifier and Type	Method	Description
void	_canceled_$eq(boolean x$1)	Deprecated.
void	aroundPostRestart(java.lang.Throwable reason)	Deprecated. INTERNAL API
void	aroundPostStop()	Deprecated. INTERNAL API
void	aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)	Deprecated. INTERNAL API
void	aroundPreStart()	Deprecated. INTERNAL API
void	aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)	Deprecated. INTERNAL API
void	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 API
void	super$aroundPostStop()	Deprecated. INTERNAL API
void	super$aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)	Deprecated. INTERNAL API
void	super$aroundPreStart()	Deprecated. INTERNAL API
void	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 interface Actor

Parameters:

receive - (undocumented)

msg - (undocumented)

aroundPreStart

void aroundPreStart()

Deprecated.

INTERNAL API

Specified by:

aroundPreStart in interface Actor

aroundPostRestart

void aroundPostRestart(java.lang.Throwable reason)

Deprecated.

INTERNAL API

Specified by:

aroundPostRestart in interface Actor

Parameters:

reason - (undocumented)

aroundPreRestart

void aroundPreRestart(java.lang.Throwable reason,
                      scala.Option<java.lang.Object> message)

Deprecated.

INTERNAL API

Specified by:

aroundPreRestart in interface Actor

Parameters:

reason - (undocumented)

message - (undocumented)

aroundPostStop

void aroundPostStop()

Deprecated.

INTERNAL API

Specified by:

aroundPostStop in interface Actor

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.