1 write to _rpc
Aspire.Hosting.Native.Client (1)
NativeClient.cs (1)
35
_rpc
= new JsonRpc(new HeaderDelimitedMessageHandler(stream, stream, new SystemTextJsonFormatter()));
11 references to _rpc
Aspire.Hosting.Native.Client (11)
NativeClient.cs (11)
36
_serverRpc =
_rpc
.Attach<INativeAppHostRpc>();
37
_rpc
.AddLocalRpcMethod("getCapabilities", new Func<JsonElement>(() =>
39
_rpc
.AddLocalRpcMethod("handleExternalCapability",
41
_rpc
.AddLocalRpcMethod("cancelProviderInvocation", new Func<string, Task<bool>>(CancelProviderInvocationAsync));
42
_rpc
.AddLocalRpcMethod("releaseIntegrationResource", new Func<string, Task<bool>>(ReleaseIntegrationResourceAsync));
43
_rpc
.AddLocalRpcMethod("invokeCallback",
45
_rpc
.Disconnected += (_, _) =>
51
_rpc
.StartListening();
170
client?.
_rpc
.Dispose();
262
internal Task WaitForDisconnectAsync(CancellationToken cancellationToken) =>
_rpc
.Completion.WaitAsync(cancellationToken);
281
_rpc
.Dispose();