10 instantiations of WaitingReadAsyncOperation
System.Threading.Channels (10)
System\Threading\Channels\BoundedChannel.cs (2)
80_waiterSingleton = new WaitingReadAsyncOperation(parent._runContinuationsAsynchronously, pooled: true); 231var waiter = new WaitingReadAsyncOperation(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\RendezvousChannel.cs (2)
70_waiterSingleton = new WaitingReadAsyncOperation(parent._runContinuationsAsynchronously, pooled: true); 216new(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (2)
63_waiterSingleton = new WaitingReadAsyncOperation(parent._runContinuationsAsynchronously, pooled: true); 186newWaitingReader = new WaitingReadAsyncOperation(_parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\UnboundedChannel.cs (2)
57_waiterSingleton = new WaitingReadAsyncOperation(parent._runContinuationsAsynchronously, pooled: true); 171new(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\UnboundedPriorityChannel.cs (2)
64_waiterSingleton = new WaitingReadAsyncOperation(parent._runContinuationsAsynchronously, pooled: true); 176new(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
33 references to WaitingReadAsyncOperation
System.Threading.Channels (33)
System\Threading\Channels\AsyncOperation.cs (1)
582internal sealed class WaitingReadAsyncOperation : AsyncOperation<WaitingReadAsyncOperation, bool>
System\Threading\Channels\BoundedChannel.cs (8)
38private WaitingReadAsyncOperation? _waitingReadersHead; 74private readonly WaitingReadAsyncOperation _waiterSingleton; 222WaitingReadAsyncOperation singleton = _waiterSingleton; 231var waiter = new WaitingReadAsyncOperation(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate); 311WaitingReadAsyncOperation? waitingReadersHead; 366WaitingReadAsyncOperation? waitingReadersHead = null; 523WaitingReadAsyncOperation? waitingReadersHead = null; 675case WaitingReadAsyncOperation waitingReader:
System\Threading\Channels\RendezvousChannel.cs (6)
32private WaitingReadAsyncOperation? _waitingReadersHead; 64private readonly WaitingReadAsyncOperation _waiterSingleton; 214WaitingReadAsyncOperation waiter = 258WaitingReadAsyncOperation? waitingReadersHead; 382WaitingReadAsyncOperation? waitingReaders = null; 469case WaitingReadAsyncOperation waitingReader:
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (6)
38private WaitingReadAsyncOperation? _waitingReader; 57private readonly WaitingReadAsyncOperation _waiterSingleton; 154WaitingReadAsyncOperation? oldWaitingReader = null, newWaitingReader; 212WaitingReadAsyncOperation? waitingReader = null; 285WaitingReadAsyncOperation? waitingReader = null; 383case WaitingReadAsyncOperation waitingReader:
System\Threading\Channels\UnboundedChannel.cs (6)
30private WaitingReadAsyncOperation? _waitingReadersHead; 51private readonly WaitingReadAsyncOperation _waiterSingleton; 169WaitingReadAsyncOperation waiter = 193WaitingReadAsyncOperation? waitingReadersHead; 243WaitingReadAsyncOperation? waitingReadersHead = null; 318case WaitingReadAsyncOperation waitingReader:
System\Threading\Channels\UnboundedPriorityChannel.cs (6)
35private WaitingReadAsyncOperation? _waitingReadersHead; 58private readonly WaitingReadAsyncOperation _waiterSingleton; 174WaitingReadAsyncOperation waiter = 199WaitingReadAsyncOperation? waitingReadersHead; 249WaitingReadAsyncOperation? waitingReadersHead = null; 324case WaitingReadAsyncOperation waitingReader: