4 instantiations of BlockedWriteAsyncOperation
System.Threading.Channels (4)
System\Threading\Channels\BoundedChannel.cs (2)
301_writerSingleton = new BlockedWriteAsyncOperation<T>(runContinuationsAsynchronously: true, pooled: true); 586var writer = new BlockedWriteAsyncOperation<T>(runContinuationsAsynchronously: true, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate)
System\Threading\Channels\RendezvousChannel.cs (2)
248_writerSingleton = new BlockedWriteAsyncOperation<T>(runContinuationsAsynchronously: true, pooled: true); 402new(parent._runContinuationsAsynchronously, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate);
15 references to BlockedWriteAsyncOperation
System.Threading.Channels (15)
System\Threading\Channels\AsyncOperation.cs (1)
569internal sealed class BlockedWriteAsyncOperation<T> : AsyncOperation<BlockedWriteAsyncOperation<T>, VoidResult>
System\Threading\Channels\BoundedChannel.cs (7)
35private BlockedWriteAsyncOperation<T>? _blockedWritersHead; 268while (ChannelUtilities.TryDequeue(ref parent._blockedWritersHead, out BlockedWriteAsyncOperation<T>? w)) 295private readonly BlockedWriteAsyncOperation<T> _writerSingleton; 310BlockedWriteAsyncOperation<T>? blockedWritersHead; 576BlockedWriteAsyncOperation<T> singleton = _writerSingleton; 586var writer = new BlockedWriteAsyncOperation<T>(runContinuationsAsynchronously: true, cancellationToken, cancellationCallback: _parent.CancellationCallbackDelegate) 671case BlockedWriteAsyncOperation<T> blockedWriter:
System\Threading\Channels\RendezvousChannel.cs (7)
29private BlockedWriteAsyncOperation<T>? _blockedWritersHead; 86BlockedWriteAsyncOperation<T>? blockedWriter = null; 141BlockedWriteAsyncOperation<T>? blockedWriter = null; 242private readonly BlockedWriteAsyncOperation<T> _writerSingleton; 257BlockedWriteAsyncOperation<T>? blockedWritersHead; 381BlockedWriteAsyncOperation<T>? writer = null; 465case BlockedWriteAsyncOperation<T> blockedWriter: