Package akka.stream.actor

Interface Summary

Interface	Description
ActorPublisher<T>	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.
ActorPublisher.Internal$.LifecycleState
ActorSubscriber	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.
RequestStrategy	Invoked by the ActorSubscriber after each incoming message to determine how many more elements to request from the stream.

Class Summary

Class	Description
AbstractActorPublisher<T>	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.
AbstractActorPublisher$	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.
AbstractActorPublisherWithStash<T>	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.
AbstractActorPublisherWithUnboundedStash<T>	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.
AbstractActorPublisherWithUnrestrictedStash<T>	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.
AbstractActorSubscriber	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.
AbstractActorSubscriber$	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.
ActorPublisher.Internal$	INTERNAL API
ActorPublisher$	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.
ActorPublisherImpl<T>	INTERNAL API
ActorPublisherImpl$
ActorPublisherMessage	INTERNAL API
ActorPublisherMessage.Cancel
ActorPublisherMessage.Cancel$
ActorPublisherMessage.Request
ActorPublisherMessage.Request$
ActorPublisherMessage.SubscriptionTimeoutExceeded
ActorPublisherMessage.SubscriptionTimeoutExceeded$	This message is delivered to the ActorPublisher actor in order to signal the exceeding of an subscription timeout.
ActorPublisherMessage$	This message is delivered to the ActorPublisher actor when the stream subscriber requests more elements.
ActorPublisherState	INTERNAL API
ActorPublisherState.State
ActorPublisherState.State$
ActorPublisherState$	INTERNAL API Some state must survive restarts.
ActorPublisherSubscription<T>	INTERNAL API
ActorSubscriber.OnSubscribe	INTERNAL API
ActorSubscriber.OnSubscribe$
ActorSubscriber$	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.
ActorSubscriberImpl<T>	INTERNAL API
ActorSubscriberMessage	INTERNAL API
ActorSubscriberMessage.OnComplete$
ActorSubscriberMessage.OnError
ActorSubscriberMessage.OnError$
ActorSubscriberMessage.OnNext
ActorSubscriberMessage.OnNext$
ActorSubscriberMessage$	Java API: get the singleton instance of the OnComplete message
ActorSubscriberState	INTERNAL API
ActorSubscriberState.State
ActorSubscriberState.State$
ActorSubscriberState$	INTERNAL API Some state must survive restarts.
MaxInFlightRequestStrategy	Concrete subclass must implement this method to define how many messages that are currently in progress or queued.
OneByOneRequestStrategy	Java API: get the singleton instance
OneByOneRequestStrategy$	Java API: get the singleton instance
UntypedActorPublisher<T>	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.
UntypedActorPublisher$	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.
UntypedActorSubscriber	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.
UntypedActorSubscriber$	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.
WatermarkRequestStrategy
WatermarkRequestStrategy$	Create WatermarkRequestStrategy with lowWatermark as half of the specified highWatermark.
ZeroRequestStrategy	Java API: get the singleton instance
ZeroRequestStrategy$	Java API: get the singleton instance