1 write to Rpc
Aspire.Hosting.Native.Core.Tests (1)
TestServices\NativeCliTestHost.cs (1)
43Rpc = new JsonRpc(new HeaderDelimitedMessageHandler(stream, stream, formatter));
26 references to Rpc
Aspire.Hosting.Native.Core.Tests (26)
NativeCliProtocolTests.cs (15)
105Assert.Equal(["baseline.v2", "pipeline-steps.v2"], await host.Rpc.InvokeAsync<string[]>("GetCapabilitiesAsync")); 110Assert.Equal(["baseline.v2", "pipeline-steps.v2"], await host.Rpc.InvokeAsync<string[]>("GetCapabilitiesAsync")); 163Assert.Equal(["baseline.v2", "pipeline-steps.v2"], await host.Rpc.InvokeAsync<string[]>("GetCapabilitiesAsync")); 164await host.Rpc.InvokeAsync("NotifyAppHostReadyAsync"); 174Assert.Equal(["baseline.v2", "pipeline-steps.v2"], await host.Rpc.InvokeAsync<string[]>("GetCapabilitiesAsync")); 176await host.Rpc.InvokeAsync("NotifyAppHostReadyAsync"); 178var dashboard = await host.Rpc.InvokeAsync<NativeCliDashboardUrls>("GetDashboardUrlsAsync"); 180await Assert.ThrowsAsync<RemoteMethodNotFoundException>(() => host.Rpc.InvokeAsync("UnknownMethod")); 182await host.Rpc.InvokeAsync("RequestStopAsync"); 190var stream = await host.Rpc.InvokeAsync<IAsyncEnumerable<NativeCliResourceState>>("GetResourceStatesAsync"); 221var stream = await host.Rpc.InvokeAsync<IAsyncEnumerable<NativeCliLogEntry>>("GetAppHostLogEntriesAsync"); 233Assert.Equal(["baseline.v2", "pipeline-steps.v2"], await host.Rpc.InvokeAsync<string[]>("GetCapabilitiesAsync")); 241var resources = await host.Rpc.InvokeAsync<IAsyncEnumerable<NativeCliResourceState>>("GetResourceStatesAsync"); 245host.Rpc.InvokeAsync<IAsyncEnumerable<NativeCliLogEntry>>("GetAppHostLogEntriesAsync")); 247var logs = await host.Rpc.InvokeAsync<IAsyncEnumerable<NativeCliLogEntry>>("GetAppHostLogEntriesAsync");
NativeIpcSecurityTests.cs (1)
49Assert.Equal(["baseline.v2", "pipeline-steps.v2"], await cli.Rpc.InvokeAsync<string[]>("GetCapabilitiesAsync"));
NativePipelineTests.cs (3)
27var inspection = host.Rpc.InvokeAsync<GetPipelineStepsResponse>("GetPipelineStepsAsync", 229host.Rpc.Disconnected += (_, _) => disconnected.TrySetResult(); 230await host.Rpc.InvokeAsync("RequestStopAsync");
NativePublishingTests.cs (5)
72var stream = await host.Rpc.InvokeAsync<IAsyncEnumerable<PublishingActivity>>("GetPublishingActivitiesAsync"); 87await host.Rpc.InvokeAsync("RequestStopAsync"); 89Assert.Equal(["baseline.v2", "pipeline-steps.v2"], await host.Rpc.InvokeAsync<string[]>("GetCapabilitiesAsync")); 100var inspection = host.Rpc.InvokeAsync<GetPipelineStepsResponse>("GetPipelineStepsAsync", new GetPipelineStepsRequest { Step = step }); 111await Assert.ThrowsAsync<RemoteMethodNotFoundException>(() => host.Rpc.InvokeAsync<GetPipelineStepsResponse>(
TestServices\NativeCliTestHost.cs (2)
44Rpc.StartListening(); 56Rpc.Dispose();