Interface IStreamPipelineBehavior<TRequest, TResponse>

Namespace

Mediarion

Assembly

Mediarion.Streaming.dll

Wraps the handling of a streaming request.

public interface IStreamPipelineBehavior<in TRequest, TResponse> where TRequest : notnull

Type Parameters

TRequest

The request this wraps, or a base of it.

TResponse

What each value is.

Remarks

A stream behaviour sees every value on its way out, so it can count them, filter them or stop early. What it cannot do is treat the request as one thing that succeeded or failed, because by the time anything has failed some values are already with the caller.

Methods

Handle(TRequest, StreamHandlerDelegate<TResponse>, CancellationToken)

Runs around the rest of the pipeline.