Class ClientEnumerableObservable<T>

Namespace

Cratis.Arc.Queries

Assembly

Cratis.Arc.Core.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.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

MethodCalls.CallGenericMethod<TOut, T>(T, Expression<Func<T, Func<TOut>>>, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1>(T, Expression<Func<T, Func<T1, TOut>>>, T1, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2>(T, Expression<Func<T, Func<T1, T2, TOut>>>, T1, T2, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2, T3>(T, Expression<Func<T, Func<T1, T2, T3, TOut>>>, T1, T2, T3, params Type[])

ConverterExtensions.ConvertTo(object, Type)

ConceptExtensions.GetConceptValue(object)

ConceptExtensions.IsConcept(object)

JsonValueExtensions.ToJsonValue(object?)

ObservableExtensions.InvokeAndWrapWithSubject<TResult>(object, Func<CancellationToken, IObservable<TResult>>)

ObservableExtensions.InvokeAndWrapWithTransformSubject<TResult, TSource>(object, Func<CancellationToken, IObservable<TSource>>, Func<TSource, TResult>)

Constructors

ClientEnumerableObservable(QueryContext, IAsyncEnumerable<T>, IReadModelInterceptors, IWebSocketConnectionHandler, IObservableQueryEmissionGuards, ILogger<IClientObservable>)

Represents an implementation of IClientEnumerableObservable.

public ClientEnumerableObservable(QueryContext queryContext, IAsyncEnumerable<T> enumerable, IReadModelInterceptors readModelInterceptors, IWebSocketConnectionHandler webSocketConnectionHandler, IObservableQueryEmissionGuards emissionGuards, ILogger<IClientObservable> logger)

Parameters

queryContext QueryContext

The QueryContext the observable is for.

enumerable IAsyncEnumerable<T>

The IAsyncEnumerable<T> to use for streaming.

readModelInterceptors IReadModelInterceptors

The IReadModelInterceptors for intercepting read models.

webSocketConnectionHandler IWebSocketConnectionHandler

The IWebSocketConnectionHandler.

emissionGuards IObservableQueryEmissionGuards

The IObservableQueryEmissionGuards consulted per emission when an application opts in with an IGuardObservableQueryEmission.

logger ILogger<IClientObservable>

The ILogger.

Methods

HandleConnection(IHttpRequestContext)

Handle the HTTP request context.

public Task HandleConnection(IHttpRequestContext context)

Parameters

context IHttpRequestContext

IHttpRequestContext to handle for.

Returns

Task

A Task representing the asynchronous operation.