Searched refs:ChannelUtilities (Results 1 – 7 of 7) sorted by relevance
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Channels/src/System/Threading/Channels/ |
H A D | BoundedChannel.cs | 93 return ChannelUtilities.s_trueTask; in WaitToReadAsync() 101 ChannelUtilities.s_falseTask; in WaitToReadAsync() 181 ChannelUtilities.Complete(parent._completion, error); in TryComplete() 189 …ChannelUtilities.FailInteractors<WriterInteractor<T>, VoidResult>(parent._blockedWriters, ChannelU… in TryComplete() 285 ChannelUtilities.s_falseTask; in WaitToWriteAsync() 293 return ChannelUtilities.s_trueTask; in WaitToWriteAsync() 333 return ChannelUtilities.s_trueTask; in WriteAsync() 343 return ChannelUtilities.s_trueTask; in WriteAsync() 357 return ChannelUtilities.s_trueTask; in WriteAsync() 367 return ChannelUtilities.s_trueTask; in WriteAsync() [all …]
|
H A D | UnboundedChannel.cs | 55 ChannelUtilities.Complete(parent._completion, parent._doneWriting); in TryRead() 68 ChannelUtilities.s_trueTask : in WaitToReadAsync() 82 return ChannelUtilities.s_trueTask; in WaitToReadAsync() 88 return parent._doneWriting != ChannelUtilities.s_doneWritingSentinel ? in WaitToReadAsync() 90 ChannelUtilities.s_falseTask; in WaitToReadAsync() 121 parent._doneWriting = error ?? ChannelUtilities.s_doneWritingSentinel; in TryComplete() 132 ChannelUtilities.Complete(parent._completion, error); in TryComplete() 140 … ChannelUtilities.WakeUpWaiters(ref parent._waitingReaders, result: false, error: error); in TryComplete() 190 ChannelUtilities.s_falseTask; in WaitToWriteAsync() 195 TryWrite(item) ? ChannelUtilities.s_trueTask : in WriteAsync() [all …]
|
H A D | UnbufferedChannel.cs | 79 ChannelUtilities.CreateInvalidCompletionException())); in ReadAsync() 99 ChannelUtilities.WakeUpWaiters(ref parent._waitingWriters, result: true); in ReadAsync() 120 ChannelUtilities.s_falseTask; in WaitToReadAsync() 126 return ChannelUtilities.s_trueTask; in WaitToReadAsync() 152 ChannelUtilities.Complete(parent._completion, error); in TryComplete() 155 …ChannelUtilities.FailInteractors<ReaderInteractor<T>, T>(parent._blockedReaders, ChannelUtilities.… in TryComplete() 156 …ChannelUtilities.FailInteractors<WriterInteractor<T>, VoidResult>(parent._blockedWriters, ChannelU… in TryComplete() 203 ChannelUtilities.s_falseTask; in WaitToWriteAsync() 209 return ChannelUtilities.s_trueTask; in WaitToWriteAsync() 235 ChannelUtilities.CreateInvalidCompletionException()); in WriteAsync() [all …]
|
H A D | SingleConsumerUnboundedChannel.cs | 62 ChannelUtilities.Complete(parent._completion, parent._doneWriting); in TryRead() 74 !_parent._items.IsEmpty ? ChannelUtilities.s_trueTask : in WaitToReadAsync() 86 return ChannelUtilities.s_trueTask; in WaitToReadAsync() 92 return parent._doneWriting != ChannelUtilities.s_doneWritingSentinel ? in WaitToReadAsync() 94 ChannelUtilities.s_falseTask; in WaitToReadAsync() 130 parent._doneWriting = error ?? ChannelUtilities.s_doneWritingSentinel; in TryComplete() 150 ChannelUtilities.Complete(parent._completion, error); in TryComplete() 210 doneWriting == null ? ChannelUtilities.s_trueTask : in WaitToWriteAsync() 211 … doneWriting != ChannelUtilities.s_doneWritingSentinel ? Task.FromException<bool>(doneWriting) : in WaitToWriteAsync() 212 ChannelUtilities.s_falseTask; in WaitToWriteAsync() [all …]
|
H A D | ChannelWriter.cs | 64 throw ChannelUtilities.CreateInvalidCompletionException(); in WriteAsync() 75 throw ChannelUtilities.CreateInvalidCompletionException(); in Complete()
|
H A D | ChannelReader.cs | 19 public virtual Task Completion => ChannelUtilities.s_neverCompletingTask;
|
H A D | ChannelUtilities.cs | 12 internal static class ChannelUtilities class
|