2 writes to ClientRpc
Aspire.Hosting.RemoteHost (2)
Ats\ExternalCapabilityRegistry.cs (2)
251ClientRpc = host, 338ClientRpc = replacement,
16 references to ClientRpc
Aspire.Hosting.RemoteHost (16)
Ats\ExternalCapabilityRegistry.cs (16)
294$"(integration hosts {previous.ClientRpc.GetHashCode()} and {host.GetHashCode()}). Capability IDs must be unique."); 355var owned = current.Values.Where(cap => ReferenceEquals(cap.ClientRpc, previous)) 452if (_unavailableHosts.TryGetValue(registration.ClientRpc, out var state)) 474invocationId, capabilityId, registration.ClientRpc.GetHashCode(), _invocationTimeout); 478var rawResult = await registration.ClientRpc.InvokeWithCancellationAsync<object?>( 509MarkHostUnavailable(registration.ClientRpc); 511$"Integration capability '{capabilityId}' (invocation {invocationId}, host {registration.ClientRpc.GetHashCode()}) " + 517invocationId, capabilityId, registration.ClientRpc.GetHashCode(), _timeProvider.GetElapsedTime(started), _invocationTimeout); 524MarkHostUnavailable(registration.ClientRpc); 528invocationId, capabilityId, registration.ClientRpc.GetHashCode(), _timeProvider.GetElapsedTime(started)); 534invocationId, capabilityId, registration.ClientRpc.GetHashCode(), _timeProvider.GetElapsedTime(started)); 540invocationId, capabilityId, registration.ClientRpc.GetHashCode(), _timeProvider.GetElapsedTime(started)); 644if (_unavailableHosts.ContainsKey(registration.ClientRpc)) 656if (_integrationCallbackInvokers.TryGetValue(registration.ClientRpc, out var hostInvoker)) 661_callbackOwners[relayId] = new CallbackOwner(registration.ClientRpc, ownerInvoker, callbackId, invocationId, registration.CapabilityId); 664relayId, invocationId, registration.CapabilityId, registration.ClientRpc.GetHashCode());