4 instantiations of WaitingWriteAsyncOperation
System.Threading.Channels (4)
System\Threading\Channels\BoundedChannel.cs (2)
302_waiterSingleton = new WaitingWriteAsyncOperation(runContinuationsAsynchronously: true, pooled: true); 509var waiter = new WaitingWriteAsyncOperation(runContinuationsAsynchronously: true, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\RendezvousChannel.cs (2)
249_waiterSingleton = new WaitingWriteAsyncOperation(runContinuationsAsynchronously: true, pooled: true); 366new(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
13 references to WaitingWriteAsyncOperation
System.Threading.Channels (13)
System\Threading\Channels\AsyncOperation.cs (1)
592internal sealed class WaitingWriteAsyncOperation : AsyncOperation<WaitingWriteAsyncOperation, bool>
System\Threading\Channels\BoundedChannel.cs (6)
41private WaitingWriteAsyncOperation? _waitingWritersHead; 296private readonly WaitingWriteAsyncOperation _waiterSingleton; 312WaitingWriteAsyncOperation? waitingWritersHead; 500WaitingWriteAsyncOperation singleton = _waiterSingleton; 509var waiter = new WaitingWriteAsyncOperation(runContinuationsAsynchronously: true, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate); 679case WaitingWriteAsyncOperation waitingWriter:
System\Threading\Channels\RendezvousChannel.cs (6)
35private WaitingWriteAsyncOperation? _waitingWritersHead; 140WaitingWriteAsyncOperation? waitingWriters = null; 243private readonly WaitingWriteAsyncOperation _waiterSingleton; 259WaitingWriteAsyncOperation? waitingWritersHead; 364WaitingWriteAsyncOperation waiter = 473case WaitingWriteAsyncOperation waitingWriter: