1 write to _outputChannel
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
86_outputChannel = Channel.CreateBounded<ReadOnlyMemory<byte>>(
4 references to _outputChannel
Aspire.TerminalHost (4)
DcpUpstreamAdapter.cs (4)
114if (!await _outputChannel.Reader.WaitToReadAsync(ct).ConfigureAwait(false)) 118if (!_outputChannel.Reader.TryRead(out var first)) 400await _outputChannel.Writer.WriteAsync(payload, ct).ConfigureAwait(false); 462_outputChannel.Writer.TryComplete(error);