1 write to _acceptedQueue
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
Internal\NamedPipeConnectionListener.cs (1)
52_acceptedQueue = Channel.CreateBounded<ConnectionContext>(new BoundedChannelOptions(capacity: 1));
6 references to _acceptedQueue
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (6)
Internal\NamedPipeConnectionListener.cs (6)
89_acceptedQueue.Writer.TryComplete(); 93_acceptedQueue.Writer.TryComplete(ex); 119while (!_acceptedQueue.Writer.TryWrite(connection)) 121if (!await _acceptedQueue.Writer.WaitToWriteAsync(_listeningToken)) 149while (await _acceptedQueue.Reader.WaitToReadAsync(cancellationToken)) 151if (_acceptedQueue.Reader.TryRead(out var connection))