Flatten the sub-flows back into the super-flow by concatenating them. This is usually a bad idea when combined with GroupBy since it can easily lead to deadlock—the concatenation does not consume from the second substream until the first has finished and the GroupBy stage will get back-pressure from the second stream.

Determines whether the specified object is equal to the current object.

Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.

Serves as the default hash function.

Gets the Type of the current instance.

TBD

Creates a shallow copy of the current Object.

Flatten the sub-flows back into the super-flow by performing a merge without parallelism limit (i.e. having an unbounded number of sub-flows active concurrently).

Flatten the sub-flows back into the super-flow by performing a merge with the given parallelism limit. This means that only up to parallelism substreams will be executed at any given time. Substreams that are not yet executed are also not materialized, meaning that back-pressure will be exerted at the operator that creates the substreams when the parallelism limit is reached.

Connect this SourceTOut, TMat to a SinkTIn, TMat and run it. The returned value is the materialized value of the SinkTIn, TMat, e.g. the IPublisher of a PublisherTIn.

Attach a Sink to each sub-flow, closing the overall Graph that is being constructed.

Returns a string that represents the current object.

TBD

TBD

TBD

Matches the specified target.

Matches the specified target and return a result of target processing.