10 instantiations of BlockedReadAsyncOperation
System.Threading.Channels (10)
System\Threading\Channels\BoundedChannel.cs (2)
79_readerSingleton = new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 184var reader = new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\RendezvousChannel.cs (2)
69_readerSingleton = new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 160new(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (2)
62_readerSingleton = new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 114newBlockedReader = new BlockedReadAsyncOperation<T>(_parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\UnboundedChannel.cs (2)
56_readerSingleton = new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 103new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
System\Threading\Channels\UnboundedPriorityChannel.cs (2)
63_readerSingleton = new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 104new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
34 references to BlockedReadAsyncOperation
System.Threading.Channels (34)
System\Threading\Channels\AsyncOperation.cs (1)
558internal sealed class BlockedReadAsyncOperation<TResult> : AsyncOperation<BlockedReadAsyncOperation<TResult>, TResult>
System\Threading\Channels\BoundedChannel.cs (8)
32private BlockedReadAsyncOperation<T>? _blockedReadersHead; 73private readonly BlockedReadAsyncOperation<T> _readerSingleton; 175BlockedReadAsyncOperation<T> singleton = _readerSingleton; 184var reader = new BlockedReadAsyncOperation<T>(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate); 309BlockedReadAsyncOperation<T>? blockedReadersHead; 365BlockedReadAsyncOperation<T>? blockedReader = null; 522BlockedReadAsyncOperation<T>? blockedReader = null; 667case BlockedReadAsyncOperation<T> blockedReader:
System\Threading\Channels\RendezvousChannel.cs (7)
26private BlockedReadAsyncOperation<T>? _blockedReadersHead; 63private readonly BlockedReadAsyncOperation<T> _readerSingleton; 139BlockedReadAsyncOperation<T>? reader = null; 256BlockedReadAsyncOperation<T>? blockedReadersHead; 308BlockedReadAsyncOperation<T>? blockedReader = null; 383BlockedReadAsyncOperation<T>? blockedReader = null; 461case BlockedReadAsyncOperation<T> blockedReader:
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (6)
35private BlockedReadAsyncOperation<T>? _blockedReader; 56private readonly BlockedReadAsyncOperation<T> _readerSingleton; 84BlockedReadAsyncOperation<T>? oldBlockedReader, newBlockedReader; 211BlockedReadAsyncOperation<T>? blockedReader = null; 284BlockedReadAsyncOperation<T>? blockedReader = null; 376case BlockedReadAsyncOperation<T> blockedReader:
System\Threading\Channels\UnboundedChannel.cs (6)
27private BlockedReadAsyncOperation<T>? _blockedReadersHead; 50private readonly BlockedReadAsyncOperation<T> _readerSingleton; 101BlockedReadAsyncOperation<T> reader = 192BlockedReadAsyncOperation<T>? blockedReadersHead; 242BlockedReadAsyncOperation<T>? blockedReader = null; 314case BlockedReadAsyncOperation<T> blockedReader:
System\Threading\Channels\UnboundedPriorityChannel.cs (6)
32private BlockedReadAsyncOperation<T>? _blockedReadersHead; 57private readonly BlockedReadAsyncOperation<T> _readerSingleton; 102BlockedReadAsyncOperation<T> reader = 198BlockedReadAsyncOperation<T>? blockedReadersHead; 248BlockedReadAsyncOperation<T>? blockedReader = null; 320case BlockedReadAsyncOperation<T> blockedReader: