Package akka.stream.actor

Interface Summary

Interface	Description
ActorPublisher<T>	Extend/mixin this trait in your Actor to make it a stream publisher that keeps track of the subscription life cycle and requested elements.
ActorPublisher.Internal$.LifecycleState
ActorSubscriber	Extend/mixin this trait in your Actor to make it a stream subscriber with full control of stream back pressure.
RequestStrategy	An ActorSubscriber defines a RequestStrategy to control the stream back pressure.

Class Summary

Class	Description
AbstractActorPublisher<T>	Java API compatible with lambda expressions
AbstractActorPublisher$	Java API compatible with lambda expressions
AbstractActorPublisherWithStash<T>	Java API compatible with lambda expressions.
AbstractActorPublisherWithUnboundedStash<T>	Java API compatible with lambda expressions.
AbstractActorPublisherWithUnrestrictedStash<T>	Java API compatible with lambda expressions.
AbstractActorSubscriber	Java API compatible with lambda expressions
AbstractActorSubscriber$	Java API compatible with lambda expressions
ActorPublisher.Internal$	INTERNAL API
ActorPublisher$
ActorPublisherImpl<T>	INTERNAL API
ActorPublisherImpl$
ActorPublisherMessage
ActorPublisherMessage.Cancel
ActorPublisherMessage.Cancel$	This message is delivered to the ActorPublisher actor when the stream subscriber cancels the subscription.
ActorPublisherMessage.Request	This message is delivered to the ActorPublisher actor when the stream subscriber requests more elements.
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$
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$
ActorSubscriberImpl<T>	INTERNAL API
ActorSubscriberMessage
ActorSubscriberMessage.OnComplete$
ActorSubscriberMessage.OnError
ActorSubscriberMessage.OnError$
ActorSubscriberMessage.OnNext
ActorSubscriberMessage.OnNext$
ActorSubscriberMessage$
ActorSubscriberState	INTERNAL API
ActorSubscriberState.State
ActorSubscriberState.State$
ActorSubscriberState$	INTERNAL API Some state must survive restarts.
MaxInFlightRequestStrategy	Requests up to the max and also takes the number of messages that have been queued internally or delegated to other actors into account.
OneByOneRequestStrategy	Requests one more element when remainingRequested is 0, i.e.
OneByOneRequestStrategy$	Requests one more element when remainingRequested is 0, i.e.
UntypedActorPublisher<T>	Java API
UntypedActorPublisher$	Java API
UntypedActorSubscriber	Java API
UntypedActorSubscriber$	Java API
WatermarkRequestStrategy
WatermarkRequestStrategy$
ZeroRequestStrategy	When request is only controlled with manual calls to ActorSubscriber.request(long).
ZeroRequestStrategy$	When request is only controlled with manual calls to ActorSubscriber.request(long).