19 references to AsyncOperation
System.Threading.Channels (19)
System\Threading\Channels\AsyncOperation.cs (1)
459base(runContinuationsAsynchronously, cancellationToken, pooled)
System\Threading\Channels\BoundedChannel.cs (6)
69_readerSingleton = new AsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 70_waiterSingleton = new AsyncOperation<bool>(parent._runContinuationsAsynchronously, pooled: true); 181var reader = new AsyncOperation<T>(parent._runContinuationsAsynchronously | cancellationToken.CanBeCanceled, cancellationToken); 235var waiter = new AsyncOperation<bool>(parent._runContinuationsAsynchronously | cancellationToken.CanBeCanceled, cancellationToken); 308_waiterSingleton = new AsyncOperation<bool>(runContinuationsAsynchronously: true, pooled: true); 518var waiter = new AsyncOperation<bool>(runContinuationsAsynchronously: true, cancellationToken);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (4)
62_readerSingleton = new AsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 63_waiterSingleton = new AsyncOperation<bool>(parent._runContinuationsAsynchronously, pooled: true); 114newBlockedReader = new AsyncOperation<T>(_parent._runContinuationsAsynchronously, cancellationToken); 186newWaitingReader = new AsyncOperation<bool>(_parent._runContinuationsAsynchronously, cancellationToken);
System\Threading\Channels\UnboundedChannel.cs (4)
51_readerSingleton = new AsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 52_waiterSingleton = new AsyncOperation<bool>(parent._runContinuationsAsynchronously, pooled: true); 107var reader = new AsyncOperation<T>(parent._runContinuationsAsynchronously, cancellationToken); 184var waiter = new AsyncOperation<bool>(parent._runContinuationsAsynchronously, cancellationToken);
System\Threading\Channels\UnboundedPriorityChannel.cs (4)
57_readerSingleton = new AsyncOperation<T>(parent._runContinuationsAsynchronously, pooled: true); 58_waiterSingleton = new AsyncOperation<bool>(parent._runContinuationsAsynchronously, pooled: true); 107var reader = new AsyncOperation<T>(parent._runContinuationsAsynchronously, cancellationToken); 188var waiter = new AsyncOperation<bool>(parent._runContinuationsAsynchronously, cancellationToken);