2 writes to _readerAwaitable
System.IO.Pipelines (2)
System\IO\Pipelines\Pipe.cs (2)
107_readerAwaitable = new PipeAwaitable(completed: false, UseSynchronizationContext); 117_readerAwaitable = new PipeAwaitable(completed: false, UseSynchronizationContext);
19 references to _readerAwaitable
System.IO.Pipelines (19)
System\IO\Pipelines\Pipe.cs (19)
407_readerAwaitable.Complete(out completionData); 416Debug.Assert(_writerAwaitable.IsCompleted || _readerAwaitable.IsCompleted); 431_readerAwaitable.Complete(out completionData); 572_readerAwaitable.SetUncompleted(); 648_readerAwaitable.Cancel(out completionData); 698_readerAwaitable.BeginOperation(token, s_signalReaderAwaitable, this); 701if (_readerAwaitable.IsCompleted) 712_readerAwaitable.SetUncompleted(); 718_readerAwaitable.BeginOperation(token, s_signalReaderAwaitable, this); 756_readerAwaitable.BeginOperation(token, s_signalReaderAwaitable, this); 759if (_readerAwaitable.IsCompleted) 783if (_unconsumedBytes > 0 || _readerAwaitable.IsCompleted) 789if (_readerAwaitable.IsRunning) 904if (_readerAwaitable.IsCompleted) 922_readerAwaitable.OnCompleted(continuation, state, flags, out completionData, out doubleCompletion); 940if (!_readerAwaitable.IsCompleted) 945cancellationTokenRegistration = _readerAwaitable.ReleaseCancellationTokenRegistration(out cancellationToken); 965bool isCanceled = _readerAwaitable.ObserveCancellation(); 1149_readerAwaitable.CancellationTokenFired(out completionData);