57 references to ChannelUtilities
System.Threading.Channels (57)
System\Threading\Channels\BoundedChannel.cs (20)
159return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent._doneWriting); 208return parent._doneWriting != ChannelUtilities.s_doneWritingSentinel ? 222ChannelUtilities.QueueWaiter(ref parent._waitingReadersTail, singleton); 236ChannelUtilities.QueueWaiter(ref _parent._waitingReadersTail, waiter); 256ChannelUtilities.Complete(parent._completion, parent._doneWriting); 285ChannelUtilities.WakeUpWaiters(ref parent._waitingWritersTail, result: true); 326parent._doneWriting = error ?? ChannelUtilities.s_doneWritingSentinel; 337ChannelUtilities.Complete(parent._completion, error); 345ChannelUtilities.FailOperations<AsyncOperation<T>, T>(parent._blockedReaders, ChannelUtilities.CreateInvalidCompletionException(error)); 346ChannelUtilities.FailOperations<VoidAsyncOperationWithData<T>, VoidResult>(parent._blockedWriters, ChannelUtilities.CreateInvalidCompletionException(error)); 347ChannelUtilities.WakeUpWaiters(ref parent._waitingReadersTail, result: false, error: error); 348ChannelUtilities.WakeUpWaiters(ref parent._waitingWritersTail, result: false, error: error); 470ChannelUtilities.WakeUpWaiters(ref waitingReadersTail, result: true); 491return parent._doneWriting != ChannelUtilities.s_doneWritingSentinel ? 512ChannelUtilities.QueueWaiter(ref parent._waitingWritersTail, singleton); 519ChannelUtilities.QueueWaiter(ref parent._waitingWritersTail, waiter); 546return new ValueTask(Task.FromException(ChannelUtilities.CreateInvalidCompletionException(parent._doneWriting))); 659ChannelUtilities.WakeUpWaiters(ref waitingReadersTail, result: true);
System\Threading\Channels\ChannelReader.cs (1)
21public virtual Task Completion => ChannelUtilities.s_neverCompletingTask;
System\Threading\Channels\ChannelWriter.cs (2)
64throw ChannelUtilities.CreateInvalidCompletionException(); 74throw ChannelUtilities.CreateInvalidCompletionException();
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (8)
96return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent._doneWriting); 130ChannelUtilities.Complete(parent._completion, parent._doneWriting); 166return parent._doneWriting != ChannelUtilities.s_doneWritingSentinel ? 225parent._doneWriting = error ?? ChannelUtilities.s_doneWritingSentinel; 251ChannelUtilities.Complete(parent._completion, error); 259error = ChannelUtilities.CreateInvalidCompletionException(error); 346doneWriting != ChannelUtilities.s_doneWritingSentinel ? new ValueTask<bool>(Task.FromException<bool>(doneWriting)) : 355new ValueTask(Task.FromException(ChannelUtilities.CreateInvalidCompletionException(_parent._doneWriting)));
System\Threading\Channels\UnboundedChannel.cs (13)
92return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent._doneWriting); 136ChannelUtilities.Complete(parent._completion, parent._doneWriting); 167return parent._doneWriting != ChannelUtilities.s_doneWritingSentinel ? 178ChannelUtilities.QueueWaiter(ref parent._waitingReadersTail, singleton); 185ChannelUtilities.QueueWaiter(ref parent._waitingReadersTail, waiter); 217parent._doneWriting = error ?? ChannelUtilities.s_doneWritingSentinel; 228ChannelUtilities.Complete(parent._completion, error); 234ChannelUtilities.FailOperations<AsyncOperation<T>, T>(parent._blockedReaders, ChannelUtilities.CreateInvalidCompletionException(error)); 235ChannelUtilities.WakeUpWaiters(ref parent._waitingReadersTail, result: false, error: error); 295ChannelUtilities.WakeUpWaiters(ref waitingReadersTail, result: true); 307doneWriting != ChannelUtilities.s_doneWritingSentinel ? new ValueTask<bool>(Task.FromException<bool>(doneWriting)) : 314new ValueTask(Task.FromException(ChannelUtilities.CreateInvalidCompletionException(_parent._doneWriting)));
System\Threading\Channels\UnboundedPriorityChannel.cs (13)
92return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent._doneWriting); 146ChannelUtilities.Complete(parent._completion, parent._doneWriting); 171return parent._doneWriting != ChannelUtilities.s_doneWritingSentinel ? 182ChannelUtilities.QueueWaiter(ref parent._waitingReadersTail, singleton); 189ChannelUtilities.QueueWaiter(ref parent._waitingReadersTail, waiter); 222parent._doneWriting = error ?? ChannelUtilities.s_doneWritingSentinel; 233ChannelUtilities.Complete(parent._completion, error); 239ChannelUtilities.FailOperations<AsyncOperation<T>, T>(parent._blockedReaders, ChannelUtilities.CreateInvalidCompletionException(error)); 240ChannelUtilities.WakeUpWaiters(ref parent._waitingReadersTail, result: false, error: error); 300ChannelUtilities.WakeUpWaiters(ref waitingReadersTail, result: true); 312doneWriting != ChannelUtilities.s_doneWritingSentinel ? ValueTask.FromException<bool>(doneWriting) : 319ValueTask.FromException(ChannelUtilities.CreateInvalidCompletionException(_parent._doneWriting));