1 write to _reader
InMemory.FunctionalTests (1)
TestTransport\InMemoryTransportConnection.cs (1)
102_reader = new ObservablePipeReader(duplexPipe.Input);
2 references to _reader
InMemory.FunctionalTests (2)
TestTransport\InMemoryTransportConnection.cs (2)
104Input = _reader; 109public Task WaitForReadTask => _reader.WaitForReadTask;