16 references to ReadAsync
Aspire.Hosting.Native.Core.Tests (15)
NativeFramingTests.cs (14)
26
Assert.Equal("\"\u00e9\"", Encoding.UTF8.GetString((await framing.
ReadAsync
(TestContext.Current.CancellationToken))!));
27
Assert.Equal("{}", Encoding.UTF8.GetString((await framing.
ReadAsync
(TestContext.Current.CancellationToken))!));
28
Assert.Null(await framing.
ReadAsync
(TestContext.Current.CancellationToken));
43
await Assert.ThrowsAsync<InvalidDataException>(() => framing.
ReadAsync
(TestContext.Current.CancellationToken));
47
Assert.Equal("{}", Encoding.UTF8.GetString((await framing.
ReadAsync
(TestContext.Current.CancellationToken))!));
55
await Assert.ThrowsAsync<InvalidDataException>(() => new NativeRpcFraming(stream).
ReadAsync
(TestContext.Current.CancellationToken));
101
Assert.Equal("{}", Encoding.UTF8.GetString((await reader.
ReadAsync
(CancellationToken.None))!));
102
Assert.Equal("null", Encoding.UTF8.GetString((await reader.
ReadAsync
(CancellationToken.None))!));
103
Assert.Null(await reader.
ReadAsync
(CancellationToken.None));
114
Assert.Equal("{\"message\":\"caf\u00e9\"}", Encoding.UTF8.GetString((await reader.
ReadAsync
(CancellationToken.None))!));
115
Assert.Equal("{}", Encoding.UTF8.GetString((await reader.
ReadAsync
(CancellationToken.None))!));
116
Assert.Null(await reader.
ReadAsync
(CancellationToken.None));
132
await Assert.ThrowsAsync<InvalidDataException>(() => reader.
ReadAsync
(CancellationToken.None));
142
await Assert.ThrowsAsync<EndOfStreamException>(() => reader.
ReadAsync
(CancellationToken.None));
TestServices\NativeSocketTestHost.cs (1)
95
public Task<byte[]?> ReadAsync(CancellationToken cancellationToken) => _framing.
ReadAsync
(cancellationToken);
Aspire.Hosting.Native.Server (1)
Rpc\NativeRpcPeer.cs (1)
84
while (await framing.
ReadAsync
(lifetime.Token).ConfigureAwait(false) is { } payload)