2 instantiations of UnboundedPrioritizedChannel
System.Threading.Channels (2)
System\Threading\Channels\Channel.netcoreapp.cs (2)
18new UnboundedPrioritizedChannel<T>(runContinuationsAsynchronously: true, comparer: null); 33return new UnboundedPrioritizedChannel<T>(!options.AllowSynchronousContinuations, options.Comparer);
12 references to UnboundedPrioritizedChannel
System.Threading.Channels (12)
System\Threading\Channels\UnboundedPriorityChannel.cs (12)
56internal readonly UnboundedPrioritizedChannel<T> _parent; 60internal UnboundedPrioritizedChannelReader(UnboundedPrioritizedChannel<T> parent) 83UnboundedPrioritizedChannel<T> parent = _parent; 112UnboundedPrioritizedChannel<T> parent = _parent; 129UnboundedPrioritizedChannel<T> parent = _parent; 136private static void CompleteIfDone(UnboundedPrioritizedChannel<T> parent) 154UnboundedPrioritizedChannel<T> parent = _parent; 190internal readonly UnboundedPrioritizedChannel<T> _parent; 192internal UnboundedPrioritizedChannelWriter(UnboundedPrioritizedChannel<T> parent) => _parent = parent; 196UnboundedPrioritizedChannel<T> parent = _parent; 246UnboundedPrioritizedChannel<T> parent = _parent; 333}, new KeyValuePair<UnboundedPrioritizedChannel<T>, AsyncOperation>(this, op));