1 write to _channel
Aspire.Hosting.TestUtilities (1)
Utils\Grpc\TestServerStreamWriter.cs (1)
20
_channel
= Channel.CreateUnbounded<T>();
5 references to _channel
Aspire.Hosting.TestUtilities (5)
Utils\Grpc\TestServerStreamWriter.cs (5)
27
_channel
.Writer.Complete(ex);
32
return
_channel
.Reader.ReadAllAsync();
37
if (await
_channel
.Reader.WaitToReadAsync())
39
_channel
.Reader.TryRead(out var message);
58
if (!
_channel
.Writer.TryWrite(message))