Click or drag to resize
Akka.NETBroadcastHub.Sink<T> Method
Creates a Sink< TIn, TMat> that receives elements from its upstream producer and broadcasts them to a dynamic set of consumers. After the Sink< TIn, TMat> returned by this method is materialized, it returns a Source< TOut, TMat> as materialized value. This Source< TOut, TMat> can be materialized arbitrary many times and each materialization will receive the broadcast elements from the original Sink<TIn, TMat>. Every new materialization of the Sink< TIn, TMat> results in a new, independent hub, which materializes to its own Source< TOut, TMat> for consuming the Sink< TIn, TMat> of that materialization. If the original Sink< TIn, TMat> is failed, then the failure is immediately propagated to all of its materialized Source< TOut, TMat> s (possibly jumping over already buffered elements). If the original Sink< TIn, TMat> is completed, then all corresponding Source< TOut, TMat> s are completed. Both failure and normal completion is "remembered" and later materializations of the Source< TOut, TMat> will see the same (failure or completion) state. Source< TOut, TMat> s that are cancelled are simply removed from the dynamic set of consumers.

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

Type Parameters

T
TBD

Return Value

Type: Sink<T, Source<T, NotUsed>>
TBD
See Also