Click or drag to resize
Akka.NETMergeHub 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 Hierarchy
SystemObject
  Akka.Streams.DslMergeHub

Namespace:  Akka.Streams.Dsl
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
public static class MergeHub
Methods
  NameDescription
Public methodStatic memberSourceT
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.
Public methodStatic memberSourceT(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.
Top
See Also