2 writes to _writerAwaitable
System.IO.Pipelines (2)
System\IO\Pipelines\Pipe.cs (2)
116
_writerAwaitable
= new PipeAwaitable(completed: true, UseSynchronizationContext);
126
_writerAwaitable
= new PipeAwaitable(completed: true, UseSynchronizationContext);
16 references to _writerAwaitable
System.IO.Pipelines (16)
System\IO\Pipelines\Pipe.cs (16)
411
_writerAwaitable
.SetUncompleted();
492
_writerAwaitable
.BeginOperation(cancellationToken, s_signalWriterAwaitable, this);
495
if (
_writerAwaitable
.IsCompleted)
521
Debug.Assert(
_writerAwaitable
.IsCompleted || _readerAwaitable.IsCompleted);
612
_writerAwaitable
.Complete(out completionData);
677
Debug.Assert(
_writerAwaitable
.IsCompleted, "PipeWriter.FlushAsync isn't completed and will deadlock");
718
_writerAwaitable
.Complete(out completionData);
769
_writerAwaitable
.Cancel(out completionData);
835
if (!
_writerAwaitable
.IsCompleted)
837
_writerAwaitable
.Complete(out completionData);
1107
if (
_writerAwaitable
.IsCompleted)
1129
if (!
_writerAwaitable
.IsCompleted)
1136
cancellationTokenRegistration =
_writerAwaitable
.ReleaseCancellationTokenRegistration(out cancellationToken);
1153
if (
_writerAwaitable
.ObserveCancellation())
1246
_writerAwaitable
.OnCompleted(continuation, state, flags, out completionData, out doubleCompletion);
1270
_writerAwaitable
.CancellationTokenFired(out completionData);