1 write to _pendingStreams
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\WebTransport\WebTransportSession.cs (1)
52
_pendingStreams
= Channel.CreateUnbounded<WebTransportStream>();
4 references to _pendingStreams
Microsoft.AspNetCore.Server.Kestrel.Core (4)
Internal\WebTransport\WebTransportSession.cs (4)
88
_pendingStreams
.Writer.Complete();
119
_pendingStreams
.Writer.Complete();
155
if (!addedToOpenStreams || !
_pendingStreams
.Writer.TryWrite(stream))
175
return await
_pendingStreams
.Reader.ReadAsync(cancellationToken);