1 write to Reader
Aspire.Hosting.Native.Core.Tests (1)
TestServices\RuntimeRpcTestContext.cs (1)
48
Reader
= Result(Observer.Invoke("joinApplicationObserver", Arguments(
14 references to Reader
Aspire.Hosting.Native.Core.Tests (14)
RuntimeRpcTests.cs (13)
24
var logs = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.
Reader
),
39
("context", context.
Reader
), ("version", initial["version"]), ("timeoutMilliseconds", JsonValue.Create(30000))));
41
Assert.Empty(Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.
Reader
))))["requests"]!.AsArray());
51
("context", context.
Reader
), ("observation", new JsonObject { ["state"] = "Running", ["healthy"] = true, ["urls"] = new JsonArray() })))));
70
Assert.Equal("HANDLE_NOT_FOUND", Error(context.Observer.Invoke("readResourceObservations", Arguments(("context", context.
Reader
)))));
84
var logs = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.
Reader
),
90
var suffix = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.
Reader
),
94
Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.
Reader
),
104
var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments(("context", context.
Reader
),
118
var prompt = Assert.Single(Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.
Reader
))))["requests"]!.AsArray())!;
121
context.Observer.Invoke("respondConfirmation", Arguments(("context", context.
Reader
),
124
Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("respondConfirmation", Arguments(("context", context.
Reader
),
135
var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments(("context", context.
Reader
),
TestServices\RuntimeRpcTestContext.cs (1)
60
public JsonNode Read() => Result(Observer.Invoke("readResourceObservations", Arguments(("context",
Reader
))));