Class ClientEnumerableObservable<T>

Namespace

Cratis.Applications.Queries

Assembly

Cratis.Applications.dll

Represents an implementation of IClientEnumerableObservable.

public class ClientEnumerableObservable<T> : IClientEnumerableObservable

Type Parameters

T

Type of data being observed.

Inheritance

object

ClientEnumerableObservable<T>

Implements

IClientEnumerableObservable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

ConverterExtensions.ConvertTo(object, Type)

Constructors

ClientEnumerableObservable(IAsyncEnumerable<T>, JsonOptions, IWebSocketConnectionHandler, ILogger<ClientEnumerableObservable<T>>)

Represents an implementation of IClientEnumerableObservable.

public ClientEnumerableObservable(IAsyncEnumerable<T> enumerable, JsonOptions jsonOptions, IWebSocketConnectionHandler webSocketConnectionHandler, ILogger<ClientEnumerableObservable<T>> logger)

Parameters

enumerable IAsyncEnumerable<T>

The IAsyncEnumerable<T> to use for streaming.

jsonOptions JsonOptions

The JsonOptions.

webSocketConnectionHandler IWebSocketConnectionHandler

The IWebSocketConnectionHandler.

logger ILogger<ClientEnumerableObservable<T>>

The ILogger.

Methods

HandleConnection(HttpContext)

Handle the HTTP context for minimal API endpoints.

public Task HandleConnection(HttpContext httpContext)

Parameters

httpContext HttpContext

HttpContext to handle for.

Returns

Task

A Task representing the asynchronous operation.