1 write to Observer
Aspire.Hosting.Native.Core.Tests (1)
TestServices\RuntimeRpcTestContext.cs (1)
39Observer = new(_server);
24 references to Observer
Aspire.Hosting.Native.Core.Tests (24)
RuntimeRpcTests.cs (20)
24var logs = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 38var wait = context.Observer.InvokeAsync("waitResourceObservations", Arguments( 41Assert.Empty(Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.Reader))))["requests"]!.AsArray()); 50Assert.Equal("TYPE_MISMATCH", Error(context.Observer.Invoke("publishObservation", Arguments( 58var root = Result(context.Observer.Call("getApplicationServer", null)); 60Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("joinResourceExecution", Arguments( 62Assert.NotNull(Result(context.Observer.Invoke("joinApplicationObserver", Arguments( 64Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("joinApplicationObserver", Arguments( 68Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("joinApplicationObserver", Arguments( 70Assert.Equal("HANDLE_NOT_FOUND", Error(context.Observer.Invoke("readResourceObservations", Arguments(("context", context.Reader))))); 84var logs = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 90var suffix = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 94Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 104var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments(("context", context.Reader), 106var completion = context.Observer.InvokeAsync("awaitRuntimeOperation", Arguments(("context", command))); 118var prompt = Assert.Single(Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.Reader))))["requests"]!.AsArray())!; 121context.Observer.Invoke("respondConfirmation", Arguments(("context", context.Reader), 124Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("respondConfirmation", Arguments(("context", context.Reader), 135var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments(("context", context.Reader), 137var result = context.Observer.InvokeAsync("awaitRuntimeOperation", Arguments(("context", command)));
TestServices\RuntimeRpcTestContext.cs (4)
48Reader = Result(Observer.Invoke("joinApplicationObserver", Arguments( 49("context", Result(Observer.Call("getApplicationServer", null))), 60public JsonNode Read() => Result(Observer.Invoke("readResourceObservations", Arguments(("context", Reader)))); 65Observer.Dispose();