SubscriberSink(TIn) Class

SubscriberSinkTIn Class

INTERNAL API Attaches a subscriber to this stream.

Inheritance Hierarchy

SystemObject
  Akka.Streams.ImplementationModule
    Akka.Streams.ImplementationAtomicModule
      Akka.Streams.ImplementationSinkModuleTIn, NotUsed
        Akka.Streams.ImplementationSubscriberSinkTIn

Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)

Syntax

Copy

public sealed class SubscriberSink<TIn> : SinkModule<TIn, NotUsed>

[<SealedAttribute>]
type SubscriberSink<'TIn> =  
    class
        inherit SinkModule<'TIn, NotUsed>
    end

Type Parameters

TIn: TBD

The SubscriberSinkTIn type exposes the following members.

Constructors

	Name	Description
	SubscriberSinkTIn	TBD

Top

Properties

	Name	Description
	Attributes	TBD (Overrides ModuleAttributes.)
	Downstreams	TBD (Inherited from AtomicModule.)
	InPorts	TBD (Inherited from Module.)
	IsAtomic	TBD (Inherited from Module.)
	IsBidiFlow	TBD (Inherited from Module.)
	IsCopied	TBD (Inherited from Module.)
	IsFlow	TBD (Inherited from Module.)
	IsFused	TBD (Inherited from Module.)
	IsRunnable	TBD (Inherited from Module.)
	IsSealed	TBD (Inherited from Module.)
	IsSink	TBD (Inherited from Module.)
	IsSource	TBD (Inherited from Module.)
	Label	TBD (Inherited from SinkModuleTIn, TMat.)
	MaterializedValueComputation	TBD (Inherited from Module.)
	OutPorts	TBD (Inherited from Module.)
	Shape	TBD (Inherited from SinkModuleTIn, TMat.)
	SubModules	TBD (Inherited from AtomicModule.)
	Upstreams	TBD (Inherited from AtomicModule.)

Top

Methods

	Name	Description
	AmendShape	TBD (Inherited from SinkModuleTIn, TMat.)
	CarbonCopy	TBD (Inherited from SinkModuleTIn, TMat.)
	CompareTo	Compares the current instance with another object of the same type and returns an integer that indicates whether the current instance precedes, follows, or occurs in the same position in the sort order as the other object. (Inherited from Module.)
	Compose(IModule)	TBD (Inherited from Module.)
	ComposeT1, T2, T3(IModule, FuncT1, T2, T3)	TBD (Inherited from Module.)
	ComposeNoMaterialized	TBD (Inherited from Module.)
	Create	TBD (Overrides SinkModuleTIn, TMatCreate(MaterializationContext, TMat).)
	Equals	Determines whether the specified object is equal to the current object. (Inherited from Object.)
	Finalize	Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.)
	Fuse(IModule, OutPort, InPort)	TBD (Inherited from Module.)
	FuseT1, T2, T3(IModule, OutPort, InPort, FuncT1, T2, T3)	TBD (Inherited from Module.)
	GetHashCode	Serves as the default hash function. (Inherited from Object.)
	GetType	Gets the Type of the current instance. (Inherited from Object.)
	MemberwiseClone	Creates a shallow copy of the current Object. (Inherited from Object.)
	Nest	TBD (Inherited from Module.)
	NewInstance	TBD (Overrides SinkModuleTIn, TMatNewInstance(SinkShapeTIn).)
	ReplaceShape	TBD (Inherited from SinkModuleTIn, TMat.)
	ToString	TBD (Inherited from SinkModuleTIn, TMat.)
	TransformMaterializedValueTMat, TMat2	TBD (Inherited from Module.)
	Wire	TBD (Inherited from Module.)
	WithAttributes	TBD (Overrides ModuleWithAttributes(Attributes).)

Top

Extension Methods

	Name	Description
	AsInstanceOfT	TBD (Defined by Extensions.)
	Match	Overloaded. Matches the specified target. (Defined by PatternMatch.)
	MatchT	Overloaded. Matches the specified target and return a result of target processing. (Defined by PatternMatch.)

Top

Reference

Akka.Streams.Implementation Namespace