Click or drag to resize
Akka.NETMergeHubSourceT Method (Int32)
Creates a SourceTOut, TMat that emits elements merged from a dynamic set of producers. After the SourceTOut, TMat returned by this method is materialized, it returns a SinkTIn, TMat as a materialized value. This SinkTIn, TMat can be materialized arbitrary many times and each of the materializations will feed the elements into the original SourceTOut, TMat. Every new materialization of the SourceTOut, TMat results in a new, independent hub, which materializes to its own SinkTIn, TMat for feeding that materialization. If one of the inputs fails the SinkTIn, TMat, the SourceTOut, TMat is failed in turn (possibly jumping over already buffered elements). Completed SinkTIn, TMats are simply removed. Once the SourceTOut, TMat is cancelled, the Hub is considered closed and any new producers using the SinkTIn, TMat will be cancelled.

Namespace:  Akka.Streams.Dsl
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax
public static Source<T, Sink<T, NotUsed>> Source<T>(
	int perProducerBufferSize
)

Parameters

perProducerBufferSize
Type: SystemInt32
Buffer space used per producer. Default value is 16.

Type Parameters

T
TBD

Return Value

Type: SourceT, SinkT, NotUsed
TBD
See Also