2 types derived from InvocationRequest
Microsoft.AspNetCore.SignalR.Client.Core (2)
Internal\InvocationRequest.cs (2)
86private sealed class Streaming : InvocationRequest 174private sealed class NonStreaming : InvocationRequest
23 references to InvocationRequest
Microsoft.AspNetCore.SignalR.Client.Core (23)
HubConnection.cs (20)
1004var irq = InvocationRequest.Stream(cancellationToken, returnType, connectionState.GetNextId(), _loggerFactory, this, activity, out channel); 1013var (irqLocal, tasks) = ((InvocationRequest, Task[]?))state!; 1355var irq = InvocationRequest.Invoke(cancellationToken, returnType, connectionState.GetNextId(), _loggerFactory, this, activity, out invocationTask); 1364var (irqLocal, tasks) = ((InvocationRequest, Task[]?))state!; 1406private async Task CancelInvocationAsync(InvocationRequest irq, Task[]? streamTasks = null) 1443private async Task InvokeCore(ConnectionState connectionState, string methodName, InvocationRequest irq, object?[] args, string[]? streams, CancellationToken cancellationToken) 1472private async Task InvokeStreamCore(ConnectionState connectionState, string methodName, InvocationRequest irq, object?[] args, string[]? streams, CancellationToken cancellationToken) 1605InvocationRequest? irq; 1766private async Task DispatchInvocationStreamItemAsync(StreamItemMessage streamItem, InvocationRequest irq) 1780private void DispatchInvocationCompletion(CompletionMessage completion, InvocationRequest irq) 2419private readonly Dictionary<string, InvocationRequest> _pendingCalls = new Dictionary<string, InvocationRequest>(StringComparer.Ordinal); 2471public void AddInvocation(InvocationRequest irq) 2487public bool TryGetInvocation(string invocationId, [NotNullWhen(true)] out InvocationRequest? irq) 2495public bool TryRemoveInvocation(string invocationId, [NotNullWhen(true)] out InvocationRequest? irq) 2517foreach (var outstandingCall in _pendingCalls.Values) 2700if (!TryGetInvocation(invocationId, out var irq)) 2712if (!TryGetInvocation(invocationId, out var irq))
Internal\InvocationRequest.cs (3)
31_cancellationTokenRegistration = cancellationToken.Register(self => ((InvocationRequest)self!).Cancel(), this); 49public static InvocationRequest Invoke(CancellationToken cancellationToken, Type resultType, string invocationId, ILoggerFactory loggerFactory, HubConnection hubConnection, Activity? activity, out Task<object?> result) 56public static InvocationRequest Stream(CancellationToken cancellationToken, Type resultType, string invocationId,