 | MergeHub Class |
A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of
producers. It consists of two parts, a SourceTOut, TMat and a SinkTIn, TMat. The SourceTOut, TMat streams the element to a consumer from
its merged inputs. Once the consumer has been materialized, the SourceTOut, TMat returns a materialized value which is
the corresponding SinkTIn, TMat. This SinkTIn, TMat can then be materialized arbitrary many times, where each of the new
materializations will feed its consumed elements to the original SourceTOut, TMat.
Inheritance HierarchyNamespace: Akka.Streams.Dsl
Assembly: Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
SyntaxMethods| Name | Description | |
|---|---|---|
  | SourceT |
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.
|
| SourceT(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.
|
See Also