Home
last modified time | relevance | path

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 DBoundedChannel.cs93 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 DUnboundedChannel.cs55 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 DUnbufferedChannel.cs79 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 DSingleConsumerUnboundedChannel.cs62 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 DChannelWriter.cs64 throw ChannelUtilities.CreateInvalidCompletionException(); in WriteAsync()
75 throw ChannelUtilities.CreateInvalidCompletionException(); in Complete()
H A DChannelReader.cs19 public virtual Task Completion => ChannelUtilities.s_neverCompletingTask;
H A DChannelUtilities.cs12 internal static class ChannelUtilities class