 | BroadcastHub.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)
Syntaxpublic static Sink<T, Source<T, NotUsed>> Sink<T>()
static member Sink : unit -> Sink<'T, Source<'T, NotUsed>>
Type Parameters
- T
- TBD
Return Value
Type:
Sink<T,
Source<T,
NotUsed>>TBD
See Also