1 implementation of Closed
Aspire.Hosting.Native.Server (1)
Rpc\NativeRpcPeer.cs (1)
27
public CancellationToken
Closed
=> _closed.Token;
7 references to Closed
Aspire.Hosting.Native.Server (7)
Rpc\NativeBackchannelRpc.cs (1)
28
using var disconnected = peer.
Closed
.Register(lifetime.Cancel);
Rpc\NativeProviderLifecycle.cs (3)
76
using var cancellation = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, deadline.Token, peer.
Closed
);
89
if (!peer.
Closed
.IsCancellationRequested)
139
if (peer is null || peer.
Closed
.IsCancellationRequested)
Rpc\NativeProviderRegistry.cs (2)
94
if (expected.Owner.IsClosed || connection.IsClosed || peer.
Closed
.IsCancellationRequested ||
447
if (registration.Disconnected || registration.Owner.IsClosed || registration.Connection.IsClosed || registration.Peer.
Closed
.IsCancellationRequested)
Rpc\NativeRpcListener.cs (1)
194
using var disconnected = peer.
Closed
.Register(connection.Dispose);