2 writes to _readerAwaitable
System.IO.Pipelines (2)
System\IO\Pipelines\Pipe.cs (2)
115_readerAwaitable = new PipeAwaitable(completed: false, UseSynchronizationContext); 125_readerAwaitable = new PipeAwaitable(completed: false, UseSynchronizationContext);
19 references to _readerAwaitable
System.IO.Pipelines (19)
System\IO\Pipelines\Pipe.cs (19)
512_readerAwaitable.Complete(out completionData); 521Debug.Assert(_writerAwaitable.IsCompleted || _readerAwaitable.IsCompleted); 536_readerAwaitable.Complete(out completionData); 679_readerAwaitable.SetUncompleted(); 759_readerAwaitable.Cancel(out completionData); 809_readerAwaitable.BeginOperation(token, s_signalReaderAwaitable, this); 812if (_readerAwaitable.IsCompleted) 823_readerAwaitable.SetUncompleted(); 829_readerAwaitable.BeginOperation(token, s_signalReaderAwaitable, this); 867_readerAwaitable.BeginOperation(token, s_signalReaderAwaitable, this); 870if (_readerAwaitable.IsCompleted) 894if (_unconsumedBytes > 0 || _readerAwaitable.IsCompleted) 900if (_readerAwaitable.IsRunning) 1015if (_readerAwaitable.IsCompleted) 1033_readerAwaitable.OnCompleted(continuation, state, flags, out completionData, out doubleCompletion); 1051if (!_readerAwaitable.IsCompleted) 1056cancellationTokenRegistration = _readerAwaitable.ReleaseCancellationTokenRegistration(out cancellationToken); 1076bool isCanceled = _readerAwaitable.ObserveCancellation(); 1260_readerAwaitable.CancellationTokenFired(out completionData);