Akka.NET Documentation
API Reference
Akka.Streams.Implementation
ActorMaterializerImpl Class
ActorPublisher Class
ActorPublisher(TOut) Class
ActorPublisherSource(TOut) Class
ActorRefSink(TIn) Class
ActorRefSinkActor Class
ActorRefSource(TOut) Class
ActorSubscriberSink(TIn) Class
ActorSubscription Class
ActorSubscription(T) Class
ActorSubscriptionWithCursor(TIn) Class
AtomicModule Class
BackpressureTimeout(T) Class
BatchingInputBuffer Class
CancelingSubscriber(T) Class
CancelSink(T) Class
Completion(T) Class
CompositeModule Class
CopiedModule Class
DelayInitial(T) Class
EmptyModule Class
EmptyPublisher(T) Class
EnumerableActorName Class
ExposedPublisherReceive Class
ExtendedActorMaterializer Class
FanIn Class
FanIn.OnComplete Structure
FanIn.OnError Structure
FanIn.OnNext Structure
FanIn.OnSubscribe Structure
FanIn(T) Class
FanIn(T).SubInput Structure
FanOut Class
FanOut.ExposedPublishers(T) Structure
FanOut.SubstreamCancel Structure
FanOut.SubstreamRequestMore Structure
FanOut.SubstreamSubscribePending Structure
FanOut.SubstreamSubscription Class
FanOut(T) Class
FirstOrDefaultStage(T) Class
FlowNameCounter Class
FusedModule Class
IActorPublisher Interface
IActorSubscription Interface
ICursor Interface
ICursors Interface
Idle(T) Class
IdleInject(TIn, TOut) Class
IdleTimeoutBidi(TIn, TOut) Class
IgnorableMaterializedValueComposites Class
IMergeBack(TIn, TMat) Interface
IModule Interface
Initial(T) Class
InputBunch Class
IPump Interface
ISpecViolation Interface
JsonObjectParser Class
LastOrDefaultStage(T) Class
MaterializerSession Class
MaterializerSession.MaterializationPanicException Class
MaybeSource(TOut) Class
Module Class
NoopSubscriptionTimeout Class
NormalShutdownException Class
NothingToReadException Class
OutputBunch(T) Class
ProcessorModule(TIn, TOut, TMat) Class
PublisherSource(TOut) Class
QueueSink(T) Class
QueueSource(TOut) Class
QueueSource(TOut).IInput Interface
QueueSource(TOut).Materialized Class
ReactiveStreamsCompliance Class
ResizableMultiReaderRingBuffer(T) Class
SeqStage(T) Class
SignalThrewException Class
SimpleOutputs Class
SinkholeSink(TIn) Class
SinkholeSubscriber(TIn) Class
SinkModule(TIn, TMat) Class
SourceModule(TOut, TMat) Class
StreamLayout Class
StreamLayout.Atomic Class
StreamLayout.Combine Class
StreamLayout.Ignore Class
StreamLayout.IMaterializedValueNode Interface
StreamLayout.Transform Class
StreamSupervisor Class
StreamSupervisor.Children Class
StreamSupervisor.GetChildren Class
StreamSupervisor.Materialize Class
StreamSupervisor.PrintDebugDump Class
StreamSupervisor.StopChildren Class
StreamSupervisor.StoppedChildren Class
SubFlowImpl(TIn, TOut, TMat, TClosed) Class
SubFusingActorMaterializerImpl Class
SubReceive Class
SubscriberSink(TIn) Class
SubscriberSource(TOut) Class
SubscriptionTimeoutException Class
Throttle(T) Class
Timers Class
TransferPhase Structure
TransferState Class
Unfold(TState, TElement) Class
UnfoldAsync(TState, TElement) Class
UnfoldResourceSource(TOut, TSource) Class
UnfoldResourceSourceAsync(TOut, TSource) Class
VirtualProcessor(T) Class
Click or drag to resize
Akka.NETQueueSourceTOutIInput Interface
TBD

Namespace:  Akka.Streams.Implementation
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
Copy
public interface IInput
See Also