Class ObservableQuerySSESubscribeRequest

Namespace

Cratis.Arc.Queries

Assembly

Cratis.Arc.Core.dll

Represents the POST body for subscribing to a query over the SSE hub transport. The ConnectionId correlates this request with an established SSE stream.

public record ObservableQuerySSESubscribeRequest : IEquatable<ObservableQuerySSESubscribeRequest>

Inheritance

object

ObservableQuerySSESubscribeRequest

Implements

IEquatable<ObservableQuerySSESubscribeRequest>

Inherited Members

object.GetType()

object.MemberwiseClone()

object.Equals(object, object)

object.ReferenceEquals(object, object)

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

ObservableQuerySSESubscribeRequest(ObservableQuerySSESubscribeRequest)

protected ObservableQuerySSESubscribeRequest(ObservableQuerySSESubscribeRequest original)

Parameters

original ObservableQuerySSESubscribeRequest

ObservableQuerySSESubscribeRequest(string, string, ObservableQuerySubscriptionRequest)

Initializes a new instance without a revision, preserving the original public constructor.

public ObservableQuerySSESubscribeRequest(string connectionId, string queryId, ObservableQuerySubscriptionRequest request)

Parameters

connectionId string

The server-assigned SSE connection identifier.

queryId string

The client-assigned query identifier.

request ObservableQuerySubscriptionRequest

The subscription details.

ObservableQuerySSESubscribeRequest(string, string, ObservableQuerySubscriptionRequest, long?)

Represents the POST body for subscribing to a query over the SSE hub transport. The ConnectionId correlates this request with an established SSE stream.

[JsonConstructor]
public ObservableQuerySSESubscribeRequest(string ConnectionId, string QueryId, ObservableQuerySubscriptionRequest Request, long? Revision = null)

Parameters

ConnectionId string

The server-assigned SSE connection identifier received in the Connected message.

QueryId string

The client-assigned identifier for this subscription.

Request ObservableQuerySubscriptionRequest

The subscription details (query name, arguments, paging, sorting).

Revision long?

The optional positive client revision used to order operations for a query id.

Properties

ConnectionId

The server-assigned SSE connection identifier received in the Connected message.

public string ConnectionId { get; init; }

Property Value

string

EqualityContract

protected virtual Type EqualityContract { get; }

Property Value

Type

QueryId

The client-assigned identifier for this subscription.

public string QueryId { get; init; }

Property Value

string

Request

The subscription details (query name, arguments, paging, sorting).

public ObservableQuerySubscriptionRequest Request { get; init; }

Property Value

ObservableQuerySubscriptionRequest

Revision

The optional positive client revision used to order operations for a query id.

public long? Revision { get; init; }

Property Value

long?

Methods

Deconstruct(out string, out string, out ObservableQuerySubscriptionRequest)

Deconstructs the original three-value contract.

public void Deconstruct(out string connectionId, out string queryId, out ObservableQuerySubscriptionRequest request)

Parameters

connectionId string

The server-assigned SSE connection identifier.

queryId string

The client-assigned query identifier.

request ObservableQuerySubscriptionRequest

The subscription details.

Deconstruct(out string, out string, out ObservableQuerySubscriptionRequest, out long?)

public void Deconstruct(out string ConnectionId, out string QueryId, out ObservableQuerySubscriptionRequest Request, out long? Revision)

Parameters

ConnectionId string

QueryId string

Request ObservableQuerySubscriptionRequest

Revision long?

Equals(ObservableQuerySSESubscribeRequest?)

public virtual bool Equals(ObservableQuerySSESubscribeRequest? other)

Parameters

other ObservableQuerySSESubscribeRequest

Returns

bool

Equals(object?)

public override bool Equals(object? obj)

Parameters

obj object

Returns

bool

GetHashCode()

public override int GetHashCode()

Returns

int

PrintMembers(StringBuilder)

protected virtual bool PrintMembers(StringBuilder builder)

Parameters

builder StringBuilder

Returns

bool

ToString()

public override string ToString()

Returns

string

Operators

operator ==(ObservableQuerySSESubscribeRequest?, ObservableQuerySSESubscribeRequest?)

public static bool operator ==(ObservableQuerySSESubscribeRequest? left, ObservableQuerySSESubscribeRequest? right)

Parameters

left ObservableQuerySSESubscribeRequest

right ObservableQuerySSESubscribeRequest

Returns

bool

operator !=(ObservableQuerySSESubscribeRequest?, ObservableQuerySSESubscribeRequest?)

public static bool operator !=(ObservableQuerySSESubscribeRequest? left, ObservableQuerySSESubscribeRequest? right)

Parameters

left ObservableQuerySSESubscribeRequest

right ObservableQuerySSESubscribeRequest

Returns

bool