8 instantiations of ConcurrentPipeWriter
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http\Http1OutputProducer.cs (1)
83_pipeWriter = new ConcurrentPipeWriter(pipeWriter, memoryPool, _contextLock);
Internal\Http2\Http2FrameWriter.cs (1)
121_outputWriter = new ConcurrentPipeWriter(outputPipeWriter, memoryPool, _writeLock);
Internal\Http2\Http2OutputProducer.cs (1)
70_pipeWriter = new ConcurrentPipeWriter(_pipe.Writer, _memoryPool, _dataWriterLock);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (5)
ConcurrentPipeWriterTests.cs (5)
30var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync); 94var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync); 191var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync); 275var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync); 343var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync);
9 references to ConcurrentPipeWriter
Microsoft.AspNetCore.Server.Kestrel.Core (4)
Internal\Http\Http1OutputProducer.cs (2)
44private readonly ConcurrentPipeWriter _pipeWriter; 347var buffer = _pipeWriter;
Internal\Http2\Http2FrameWriter.cs (1)
77private readonly ConcurrentPipeWriter _outputWriter;
Internal\Http2\Http2OutputProducer.cs (1)
33private readonly ConcurrentPipeWriter _pipeWriter;
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (5)
ConcurrentPipeWriterTests.cs (5)
30var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync); 94var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync); 191var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync); 275var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync); 343var concurrentPipeWriter = new ConcurrentPipeWriter(mockPipeWriter, diagnosticPool, sync);