Class ObservableQueryExtensions
- Namespace
- Cratis.Applications.Queries
- Assembly
- Cratis.Applications.dll
Provides extension methods for working with observable queries.
public static class ObservableQueryExtensions- Inheritance
-
ObservableQueryExtensions
- Inherited Members
Methods
CreateClientEnumerableObservableFrom(IServiceProvider, ObjectResult, JsonOptions)
Creates a client enumerable observable from an object result.
public static IClientEnumerableObservable CreateClientEnumerableObservableFrom(IServiceProvider serviceProvider, ObjectResult objectResult, JsonOptions options)Parameters
serviceProviderIServiceProviderThe service provider.
objectResultObjectResultThe object result.
optionsJsonOptionsThe JSON options.
Returns
- IClientEnumerableObservable
The client enumerable observable.
CreateClientEnumerableObservableFrom<T>(IServiceProvider, IAsyncEnumerable<T>, JsonOptions)
Creates a client enumerable observable from an async enumerable directly.
public static IClientEnumerableObservable CreateClientEnumerableObservableFrom<T>(IServiceProvider serviceProvider, IAsyncEnumerable<T> enumerable, JsonOptions options)Parameters
serviceProviderIServiceProviderThe service provider.
enumerableIAsyncEnumerable<T>The async enumerable to wrap.
optionsJsonOptionsThe JSON options.
Returns
- IClientEnumerableObservable
The client enumerable observable.
Type Parameters
TThe type of data being enumerated.
CreateClientObservableFrom(IServiceProvider, ObjectResult, IQueryContextManager, JsonOptions)
Creates a client observable from an object result.
public static IClientObservable CreateClientObservableFrom(IServiceProvider serviceProvider, ObjectResult objectResult, IQueryContextManager queryContextManager, JsonOptions options)Parameters
serviceProviderIServiceProviderThe service provider.
objectResultObjectResultThe object result.
queryContextManagerIQueryContextManagerThe query context manager.
optionsJsonOptionsThe JSON options.
Returns
- IClientObservable
The client observable.
CreateClientObservableFrom<T>(IServiceProvider, ISubject<T>, QueryContext, JsonOptions)
Creates a client observable from a subject directly.
public static IClientObservable CreateClientObservableFrom<T>(IServiceProvider serviceProvider, ISubject<T> subject, QueryContext queryContext, JsonOptions options)Parameters
serviceProviderIServiceProviderThe service provider.
subjectISubject<T>The subject to wrap.
queryContextQueryContextThe query context.
optionsJsonOptionsThe JSON options.
Returns
- IClientObservable
The client observable.
Type Parameters
TThe type of data being observed.
HandleWebSocketHeadersForMultipleProxies(HttpContext, ILogger?)
Handles WebSocket headers for connections that are going through multiple proxies.
public static void HandleWebSocketHeadersForMultipleProxies(this HttpContext httpContext, ILogger? logger = null)Parameters
httpContextHttpContextThe HTTP context to handle for.
loggerILoggerOptional logger for diagnostics.
IsAsyncEnumerableResult(ObjectResult)
Determines if the result is an AsyncEnumerable result.
public static bool IsAsyncEnumerableResult(this ObjectResult objectResult)Parameters
objectResultObjectResultThe object result to check.
Returns
- bool
True if it's an AsyncEnumerable result, false otherwise.
IsStreamingResult(ObjectResult)
Determines if the result is a streaming result (Subject or AsyncEnumerable).
public static bool IsStreamingResult(this ObjectResult objectResult)Parameters
objectResultObjectResultThe object result to check.
Returns
- bool
True if it's a streaming result, false otherwise.
IsSubjectResult(ObjectResult)
Determines if the result is a Subject result.
public static bool IsSubjectResult(this ObjectResult objectResult)Parameters
objectResultObjectResultThe object result to check.
Returns
- bool
True if it's a Subject result, false otherwise.