Akka.Streams.Implementation Namespace

TBD

Classes

	Class	Description
	ActorMaterializerImpl	TBD
	ActorPublisher	TBD
	ActorPublisherTOut	INTERNAL API When you instantiate this class, or its subclasses, you MUST send an ExposedPublisher message to the wrapped ActorRef! If you don't need to subclass, prefer the apply() method on the companion object which takes care of this.
	ActorPublisherSourceTOut	INTERNAL API Creates and wraps an actor into IPublisher from the given Props, which should be props for an ActorPublisherTOut.
	ActorRefSinkTIn	INTERNAL API
	ActorRefSinkActor	TBD
	ActorRefSourceTOut	INTERNAL API
	ActorSubscriberSinkTIn	INTERNAL API Creates and wraps an actor into ISubscriber from the given Props, which should be Props for an ActorSubscriber.
	ActorSubscription	TBD
	ActorSubscriptionT	TBD
	ActorSubscriptionWithCursorTIn	TBD
	AtomicModule	This is the only extension point for the sealed type hierarchy: composition (i.e. the module tree) is managed strictly within this file, only leaf nodes may be declared elsewhere.
	BackpressureTimeoutT	INTERNAL API
	BatchingInputBuffer	TBD
	CancelingSubscriberT	A subscriber who calls Cancel directly from OnSubscribe(ISubscription) and ignores all other callbacks.
	CancelSinkT	INTERNAL API A sink that immediately cancels its upstream upon materialization.
	CompletionT	INTERNAL API
	CompositeModule	TBD
	CopiedModule	TBD
	DelayInitialT	INTERNAL API
	EmptyModule	TBD
	EmptyPublisherT	TBD
	EnumerableActorName	Generator of sequentially numbered actor names.
	ExposedPublisherReceive	TBD
	ExtendedActorMaterializer	ExtendedActorMaterializer used by subtypes which materializer using GraphInterpreterShell
	FanIn	TBD
	FanInT	TBD
	FanOut	INTERNAL API
	FanOutSubstreamSubscription	TBD
	FanOutT	INTERNAL API
	FirstOrDefaultStageT	INTERNAL API
	FlowNameCounter	TBD
	FusedModule	TBD
	IdleT	INTERNAL API
	IdleInjectTIn, TOut	INTERNAL API
	IdleTimeoutBidiTIn, TOut	INTERNAL API
	IgnorableMaterializedValueComposites	TBD
	InitialT	INTERNAL API
	InputBunch	TBD
	JsonObjectParser	INTERNAL API: Use JsonFraming instead Mutable framing implementation that given any number of ByteString chunks, can emit JSON objects contained within them. Typically JSON objects are separated by new-lines or commas, however a top-level JSON Array can also be understood and chunked up into valid JSON objects by this framing implementation. Leading whitespace between elements will be trimmed.
	LastOrDefaultStageT	INTERNAL API
	MaterializerSession	INTERNAL API
	MaterializerSessionMaterializationPanicException	TBD
	MaybeSourceTOut	INTERNAL API
	Module	TBD
	NoopSubscriptionTimeout	INTERNAL API Subscription timeout which does not start any scheduled events and always returns `true`. This specialized implementation is to be used for "noop" timeout mode.
	NormalShutdownException	TBD
	NothingToReadException	TBD
	OutputBunchT	TBD
	ProcessorModuleTIn, TOut, TMat	INTERNAL API
	PublisherSourceTOut	INTERNAL API Construct a transformation starting with given publisher. The transformation steps are executed by a series of IProcessor instances that mediate the flow of elements downstream and the propagation of back-pressure upstream.
	QueueSinkT	INTERNAL API
	QueueSourceTOut	INTERNAL API
	QueueSourceTOutMaterialized	TBD
	ReactiveStreamsCompliance	TBD
	ResizableMultiReaderRingBufferT	INTERNAL API A mutable RingBuffer that can grow in size and supports multiple readers. Contrary to many other ring buffer implementations this one does not automatically overwrite the oldest elements, rather, if full, the buffer tries to grow and rejects further writes if max capacity is reached.
	SeqStageT	INTERNAL API
	SignalThrewException	TBD
	SimpleOutputs	TBD
	SinkholeSinkTIn	INTERNAL API Attaches a subscriber to this stream which will just discard all received elements.
	SinkholeSubscriberTIn	INTERNAL API
	SinkModuleTIn, TMat	INTERNAL API
	SourceModuleTOut, TMat	INTERNAL API
	StreamLayout	TBD
	StreamLayoutAtomic	TBD
	StreamLayoutCombine	TBD
	StreamLayoutIgnore	TBD
	StreamLayoutTransform	TBD
	StreamSupervisor	TBD
	StreamSupervisorChildren	TBD
	StreamSupervisorGetChildren	TBD
	StreamSupervisorMaterialize	TBD
	StreamSupervisorPrintDebugDump	TBD
	StreamSupervisorStopChildren	TBD
	StreamSupervisorStoppedChildren	TBD
	SubFlowImplTIn, TOut, TMat, TClosed	TBD
	SubFusingActorMaterializerImpl	TBD
	SubReceive	TBD
	SubscriberSinkTIn	INTERNAL API Attaches a subscriber to this stream.
	SubscriberSourceTOut	INTERNAL API Holds a `Subscriber` representing the input side of the flow. The `Subscriber` can later be connected to an upstream `Publisher`.
	SubscriptionTimeoutException	TBD
	ThrottleT	INTERNAL API
	Timers	INTERNAL API Various stages for controlling timeouts on IO related streams (although not necessarily). The common theme among the processing stages here that - they wait for certain event or events to happen - they have a timer that may fire before these events - if the timer fires before the event happens, these stages all fail the stream - otherwise, these streams do not interfere with the element flow, ordinary completion or failure
	TransferState	TBD
	UnfoldTState, TElement	INTERNAL API
	UnfoldAsyncTState, TElement	INTERNAL API
	UnfoldResourceSourceTOut, TSource	INTERNAL API
	UnfoldResourceSourceAsyncTOut, TSource	INTERNAL API
	VirtualProcessorT	TBD

Structures

	Structure	Description
	FanInOnComplete	TBD
	FanInOnError	TBD
	FanInOnNext	TBD
	FanInOnSubscribe	TBD
	FanInTSubInput	TBD
	FanOutExposedPublishersT	TBD
	FanOutSubstreamCancel	TBD
	FanOutSubstreamRequestMore	TBD
	FanOutSubstreamSubscribePending	TBD
	TransferPhase	TBD

Interfaces

	Interface	Description
	IActorPublisher	TBD
	IActorSubscription	TBD
	ICursor	TBD
	ICursors	TBD
	IMergeBackTIn, TMat	TBD
	IModule	TBD
	IPump	TBD
	ISpecViolation	TBD
	QueueSourceTOutIInput	TBD
	StreamLayoutIMaterializedValueNode	TBD