Click or drag to resize
Akka.NETMergeHub Methods
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