1 write to _bufferedData
Microsoft.AspNetCore.WebSockets.Tests (1)
BufferStream.cs (1)
28_bufferedData = new ConcurrentQueue<byte[]>();
6 references to _bufferedData
Microsoft.AspNetCore.WebSockets.Tests (6)
BufferStream.cs (6)
121while (!_bufferedData.TryDequeue(out topBuffer)) 142while (count > 0 && (_topBuffer.Count > 0 || !_bufferedData.IsEmpty)); 185while (!_bufferedData.TryDequeue(out topBuffer)) 206while (count > 0 && (_topBuffer.Count > 0 || !_bufferedData.IsEmpty)); 233_bufferedData.Enqueue(internalBuffer); 295if (!_bufferedData.IsEmpty || _disposed)