1 write to _channel
Aspire.Hosting.Tests (1)
Utils\Grpc\TestServerStreamWriter.cs (1)
18
_channel
= Channel.CreateUnbounded<T>();
5 references to _channel
Aspire.Hosting.Tests (5)
Utils\Grpc\TestServerStreamWriter.cs (5)
25
_channel
.Writer.Complete();
30
return
_channel
.Reader.ReadAllAsync();
35
if (await
_channel
.Reader.WaitToReadAsync())
37
_channel
.Reader.TryRead(out var message);
52
if (!
_channel
.Writer.TryWrite(message))