Method CreateStream

Namespace

Mediarion

Assembly

Mediarion.Streaming.dll

CreateStream<TResponse>(ISender, IStreamRequest<TResponse>, CancellationToken)

Sends a streaming request.

public static IAsyncEnumerable<TResponse> CreateStream<TResponse>(this ISender sender, IStreamRequest<TResponse> request, CancellationToken cancellationToken = default)

Parameters

sender ISender

The sender.

request IStreamRequest<TResponse>

The request.

cancellationToken CancellationToken

Stops the stream.

Returns

IAsyncEnumerable<TResponse>

The values, as they are produced.

Type Parameters

TResponse

What each value is.

CreateStream(ISender, object, CancellationToken)

Sends a streaming request whose type is only known at run time.

public static IAsyncEnumerable<object?> CreateStream(this ISender sender, object request, CancellationToken cancellationToken = default)

Parameters

sender ISender

The sender.

request object

The request.

cancellationToken CancellationToken

Stops the stream.

Returns

IAsyncEnumerable<object>

The values, boxed, as they are produced.