Add the given attributes to this SourceTOut, TMat. Further calls to WithAttributes(Attributes) will not remove these attributes. Note that this operation has no effect on an empty Flow (because the attributes apply only to the contained processing stages).

Put an asynchronous boundary around this Source.

Combines several sources with fun-in strategy like MergeTIn, TOut or ConcatTIn, TOut and returns SourceTOut, TMat.

Concatenate the given SourceTOut, TMat to this FlowTIn, TOut, TMat, meaning that once this Flow’s input is exhausted and all result elements have been generated, the Source’s elements will be produced. Note that the SourceTOut, TMat is materialized together with this Flow and just kept from producing elements by asserting back-pressure until its time comes. If this FlowTIn, TOut, TMat gets upstream error - no elements from the given SourceTOut, TMat will be pulled. @see ConcatTIn, TOut. It is recommended to use the internally optimized LeftTLeft, TRight(TLeft, TRight) and RightTLeft, TRight(TLeft, TRight) combiners where appropriate instead of manually writing functions that pass through one of the values.

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.

Transform only the materialized value of this Source, leaving all other properties as they were.

Creates a shallow copy of the current Object.

Add a name attribute to this Source.

Shortcut for running this SourceTOut, TMat with a fold function. The given function is invoked for every received element, giving it its previous output (or the given zero value) and the element as input. The returned TaskTResult will be completed with value of the final function evaluation when the input stream ends, or completed with Failure if there is a failure signaled in the stream.

Shortcut for running this SourceTOut, TMat with a async aggregate function. The given function is invoked for every received element, giving it its previous output (or the given zero value) and the element as input. The returned TaskTResult will be completed with value of the final function evaluation when the input stream ends, or completed with Failure if there is a failure signaled in the stream.

Shortcut for running this SourceTOut, TMat with a foreach procedure. The given procedure is invoked for each received element. The returned Task will be completed with Success when reaching the normal end of the stream, or completed with Failure if there is a failure signaled in the stream.

Shortcut for running this SourceTOut, TMat with a reduce function. The given function is invoked for every received element, giving it its previous output (from the second element) and the element as input. The returned TaskTResult will be completed with value of the final function evaluation when the input stream ends, or completed with Failure if there is a failure signaled in the stream.

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.

Connect this SourceTOut, TMat to a SinkTIn, TMat, concatenating the processing steps of both.

Connect this SourceTOut, TMat to a SinkTIn, TMat, concatenating the processing steps of both.

TBD

Transform this SourceTOut, TMat by appending the given processing steps. The materialized value of the combined SourceTOut, TMat will be the materialized value of the current flow (ignoring the other flow’s value), use ViaMaterializedTOut2, TMat2, TMat3(IGraphFlowShapeTOut, TOut2, TMat2, FuncTMat, TMat2, TMat3) if a different strategy is needed.

Transform this SourceTOut, TMat by appending the given processing steps. The combine function is used to compose the materialized values of this flow and that flow into the materialized value of the resulting Flow.

Nests the current Source and returns a Source with the given Attributes

Combine the elements of multiple streams into a stream of lists.

Combine the elements of multiple streams into a stream of sequences using a combiner function.

TBD

Matches the specified target.

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