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