Package akka.stream.impl.fusing

Interface Summary

Interface	Description
ActorGraphInterpreter.BoundaryEvent
ActorGraphInterpreter.SimpleBoundaryEvent
SubSink.Command
SubSink.State

Class Summary

Class	Description
ActorGraphInterpreter	INTERNAL API
ActorGraphInterpreter.ActorOutputBoundary
ActorGraphInterpreter.BatchingActorInputBoundary
ActorGraphInterpreter.Cancel
ActorGraphInterpreter.Cancel$
ActorGraphInterpreter.OutputBoundaryPublisher
ActorGraphInterpreter.RequestMore
ActorGraphInterpreter.RequestMore$
ActorGraphInterpreter.Resume$
ActorGraphInterpreter.Snapshot$
ActorGraphInterpreter.SubscribePending
ActorGraphInterpreter.SubscribePending$
ActorGraphInterpreter$	INTERNAL API
Batch<In,Out>	INTERNAL API
Batch$
Buffer<T>	INTERNAL API
Buffer$
Collect<In,Out>
Collect$
Delay<T>	INTERNAL API
Drop<T>	INTERNAL API
Drop$
DropWhile<T>	INTERNAL API
DropWhile$
DropWithin<T>	INTERNAL API
Expand<In,Out>	INTERNAL API
Filter<T>	INTERNAL API
Filter$
FlattenMerge<T,M>	INTERNAL API
Fold<In,Out>	INTERNAL API
Fold$
FoldAsync<In,Out>	INTERNAL API
GraphInterpreter	INTERNAL API
GraphInterpreter.Connection	INERNAL API
GraphInterpreter.DownstreamBoundaryStageLogic<T>
GraphInterpreter.Empty$	Marker object that indicates that a port holds no element since it was already grabbed.
GraphInterpreter.Failed
GraphInterpreter.Failed$
GraphInterpreter.UpstreamBoundaryStageLogic<T>
GraphInterpreter$	Compile time constant, enable it for debug logging to the console.
GraphInterpreterShell	param: promise Will be completed upon processing the event, or failed if processing the event throws if the event isn't ever processed the promise (the operator stops) is failed elsewhere
GraphStageModule<S extends Shape,M>	INTERNAL API
GraphStageModule$
GraphStages	INTERNAL API
GraphStages.Detacher<T>	INTERNAL API
GraphStages.FutureFlattenSource<T,M>
GraphStages.FutureSource<T>
GraphStages.IgnoreSink$
GraphStages.SimpleLinearGraphStage<T>
GraphStages.SingleSource<T>
GraphStages.TickSource<T>
GraphStages$	INTERNAL API
GroupBy<T,K>	INTERNAL API
GroupBy$
Grouped<T>	INTERNAL API
Grouped$
GroupedWeightedWithin<T>	INTERNAL API
GroupedWeightedWithin$
Intersperse<T>	INTERNAL API
Intersperse$
LazyFlow<I,O,M>	INTERNAL API
LimitWeighted<T>	INTERNAL API
LimitWeighted$
Log<T>	INTERNAL API
Log$	Must be located here to be visible for implicit resolution, when Materializer is passed to Logging More specific LogSource than fromString, which would add the ActorSystem name in addition to the supervision to the log source.
Map<In,Out>	INTERNAL API
Map$
MapAsync<In,Out>
MapAsync.Holder<T>
MapAsync$	INTERNAL API
MapAsyncUnordered<In,Out>	INTERNAL API
MapAsyncUnordered$
MapError<T>	Maps error with the provided function if it is defined for an error or, otherwise, passes it on unchanged.
MapError$
PrefixAndTail<T>	INTERNAL API
Recover<T>	INTERNAL API
Recover$
RecoverWith<T,M>
RecoverWith$	INTERNAL API
Reduce<T>	INTERNAL API
Scan<In,Out>	INTERNAL API
Scan$
ScanAsync<In,Out>	INTERNAL API
ScanAsync$
Sliding<T>	INTERNAL API
Sliding$
Split<T>	INTERNAL API
Split.SplitAfter$
Split.SplitBefore$
Split.SplitDecision
Split$	Splits before the current element.
StatefulMapConcat<In,Out>	INTERNAL API
SubSink<T>	INTERNAL API
SubSink.Cancel$
SubSink.CancelScheduledBeforeMaterialization$
SubSink.CommandScheduledBeforeMaterialization
SubSink.RequestOne$
SubSink.RequestOneScheduledBeforeMaterialization$
SubSink.Uninitialized$
SubSink$	Not yet materialized and no command has been scheduled
SubSource<T>	INTERNAL API
SupervisedGraphStageLogic	INTERNAL API
Take<T>	INTERNAL API
Take$
TakeWhile<T>	INTERNAL API
TakeWhile$
TakeWithin<T>	INTERNAL API
TimerKeys	INTERNAL API
TimerKeys.DropWithinTimerKey$
TimerKeys.GroupedWithinTimerKey$
TimerKeys.TakeWithinTimerKey$
TimerKeys$	INTERNAL API
Watch<T>
Watch$