Interface IStreamPipelineBehavior<TRequest, TResponse>

Namespace

Caesar

Assembly

Caesar.Abstractions.dll

Wraps the handling of a streaming request.

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

Type Parameters

TRequest

The request type.

TResponse

The item type.

Methods

Handle(TRequest, StreamHandlerDelegate<TResponse>, CancellationToken)

Handles the request, calling next to obtain the inner stream.

IAsyncEnumerable<TResponse> Handle(TRequest request, StreamHandlerDelegate<TResponse> next, CancellationToken cancellationToken)

Parameters

request TRequest

The request.

next StreamHandlerDelegate<TResponse>

Continues the pipeline.

cancellationToken CancellationToken

Cancellation token.

Returns

IAsyncEnumerable<TResponse>