Add the given attributes to this SinkTIn, 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 Sink.

Transform this Sink by applying a function to each *incoming* upstream element before it is passed to the Sink Backpressures when original Sink backpressures Cancels when original Sink backpressures

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 Sink, leaving all other properties as they were.

Creates a shallow copy of the current Object.

Add a name attribute to this Sink.

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

TBD

Change the attributes of this SinkTIn, TMat to the given ones and seal the list of attributes. This means that further calls will not be able to remove these attributes, but instead add new ones. Note that this operation has no effect on an empty Flow (because the attributes apply only to the contained processing stages).

TBD

Matches the specified target.

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