| MergeHubSourceT 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
)
static member Source :
perProducerBufferSize : int -> Source<'T, Sink<'T, NotUsed>>
Parameters
- perProducerBufferSize
- Type: SystemInt32
Buffer space used per producer. Default value is 16.
Type Parameters
- T
- TBD
Return Value
Type:
SourceT,
SinkT,
NotUsedTBD
See Also