Class QuerySubscriber

Namespace

Cratis.Arc.Queries

Assembly

Cratis.Arc.Core.dll

Represents a single active subscriber for a query, combining connection and subscription data.

public sealed record QuerySubscriber : IEquatable<QuerySubscriber>

Inheritance

object

QuerySubscriber

Implements

IEquatable<QuerySubscriber>

Inherited Members

object.GetType()

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

QuerySubscriber()

public QuerySubscriber()

Properties

ClientInfo

Gets client identity and transport information for this subscriber.

public required QuerySubscriptionClientInfo ClientInfo { get; init; }

Property Value

QuerySubscriptionClientInfo

ConnectedAt

Gets when this subscription was first established.

public required DateTimeOffset ConnectedAt { get; init; }

Property Value

DateTimeOffset

ConnectionId

Gets the connection identifier (e.g. ws-1 for WebSocket, a GUID for SSE).

public required string ConnectionId { get; init; }

Property Value

string

LastDataServedAt

Gets the last time data was served to this subscriber.

public DateTimeOffset? LastDataServedAt { get; init; }

Property Value

DateTimeOffset?

LastPingSentAt

Gets the last time a ping was sent to this subscriber.

public DateTimeOffset? LastPingSentAt { get; init; }

Property Value

DateTimeOffset?

LastPongReceivedAt

Gets the last time a pong was received from this subscriber.

public DateTimeOffset? LastPongReceivedAt { get; init; }

Property Value

DateTimeOffset?

Protocol

Gets the transport protocol (WebSocket or SSE).

public required string Protocol { get; init; }

Property Value

string

SubscriptionId

Gets the subscription identifier — the client-generated query ID.

public required string SubscriptionId { get; init; }

Property Value

string

Methods

Equals(QuerySubscriber?)

public bool Equals(QuerySubscriber? other)

Parameters

other QuerySubscriber

Returns

bool

Equals(object?)

public override bool Equals(object? obj)

Parameters

obj object

Returns

bool

GetHashCode()

public override int GetHashCode()

Returns

int

ToString()

public override string ToString()

Returns

string

Operators

operator ==(QuerySubscriber?, QuerySubscriber?)

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

Parameters

left QuerySubscriber

right QuerySubscriber

Returns

bool

operator !=(QuerySubscriber?, QuerySubscriber?)

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

Parameters

left QuerySubscriber

right QuerySubscriber

Returns

bool