1 instantiation of CallbackOwner
Aspire.Hosting.RemoteHost (1)
Ats\ExternalCapabilityRegistry.cs (1)
661
_callbackOwners[relayId] = new
CallbackOwner
(registration.ClientRpc, ownerInvoker, callbackId, invocationId, registration.CapabilityId);
4 references to CallbackOwner
Aspire.Hosting.RemoteHost (4)
Ats\ExternalCapabilityRegistry.cs (4)
35
private readonly ConcurrentDictionary<string,
CallbackOwner
> _callbackOwners = new(StringComparer.Ordinal);
550
=> _callbackOwners.TryGetValue(callbackId, out
var
owner) ? (owner.Invoker, owner.CallbackId) : null;
554
if (!_callbackOwners.TryGetValue(callbackId, out
var
owner) || !ReferenceEquals(owner.Host, host))
622
private void RemoveCallbackOwners(Func<
CallbackOwner
, bool> predicate)