1 write to _channel
Aspire.Hosting.Tests (1)
Utils\Grpc\TestAsyncStreamReader.cs (1)
18
_channel
= Channel.CreateUnbounded<T>();
4 references to _channel
Aspire.Hosting.Tests (4)
Utils\Grpc\TestAsyncStreamReader.cs (4)
24
if (!
_channel
.Writer.TryWrite(message))
32
_channel
.Writer.Complete();
39
if (await
_channel
.Reader.WaitToReadAsync(cancellationToken) &&
40
_channel
.Reader.TryRead(out var message))