| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/ |
| H A D | OutputAvailableTest.cs | 39 var task = source.OutputAvailableAsync(); in ImmediateTest()
53 var task = source.OutputAvailableAsync(); in PostponedTest()
69 var task = source.OutputAvailableAsync(); in CompletedImmediateTest()
80 var task = source.OutputAvailableAsync(); in CompletedPostponedTest()
96 var task = source.OutputAvailableAsync(); in FaultedImmediateTest()
107 var task = source.OutputAvailableAsync(); in FaultedPostponedTest()
124 var task = source.OutputAvailableAsync(); in WithTargetTest()
138 var task = source.OutputAvailableAsync(); in WithDecliningTargetTest()
152 var task = source.OutputAvailableAsync(tokenSource.Token); in CancellationTest()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
| H A D | DataflowBlockExtensionTests.cs | 395 Task<bool> second = targets[1].OutputAvailableAsync(); in TestAsObservableAndAsObserver_BroadcastBackPressure()
1862 buffer.OutputAvailableAsync(); in TestOutputAvailableAsync_AvailabilityBeforeAfterData()
1872 buffer.OutputAvailableAsync(); in TestOutputAvailableAsync_AvailabilityBeforeAfterData()
1894 buffer.OutputAvailableAsync(); in TestOutputAvailableAsync_NoDataAfterCompletion()
1916 wob.OutputAvailableAsync(new CancellationTokenSource().Token) : in TestOutputAvailableAsync_DataAfterCompletion()
1917 wob.OutputAvailableAsync(); in TestOutputAvailableAsync_DataAfterCompletion()
1929 Task t = source.OutputAvailableAsync(); in TestOutputAvailableAsync_LongSequence()
1932 t = t.ContinueWith(_ => source.OutputAvailableAsync(), in TestOutputAvailableAsync_LongSequence()
1948 var t = buffer.OutputAvailableAsync(cts.Token); in TestOutputAvailableAsync_Cancellation()
1954 t = buffer.OutputAvailableAsync(cts.Token); in TestOutputAvailableAsync_Cancellation()
[all …]
|
| H A D | BufferBlockTests.cs | 175 … Assert.True(await bb.OutputAvailableAsync()); // wait for previously posted/sent item in TestBoundedReceives()
245 while (await bb.OutputAvailableAsync()) in TestProducerConsumer()
327 var outputAvailableAsync = buffer.OutputAvailableAsync(); in TestOutputAvailableAsyncAfterTryReceiveAll()
|
| H A D | BatchBlockTests.cs | 183 … Assert.True(await bb.OutputAvailableAsync()); // wait for previously posted/sent item in TestBoundedReceives()
244 while (await bb.OutputAvailableAsync()) in TestProducerConsumer()
293 Assert.Equal(expected: true, actual: await batch.OutputAvailableAsync()); in TestNonGreedy()
545 await b.OutputAvailableAsync(); in TestCompletionWithBufferedItems()
|
| H A D | TransformManyBlockTests.cs | 213 while (await tb.OutputAvailableAsync()) in TestProducerConsumer()
587 while (await tb.OutputAvailableAsync()) in TestYieldingNoResults()
|
| H A D | DebugAttributeTests.cs | 159 slt.OutputAvailableAsync(); in CreateOutputAvailableTarget()
|
| H A D | TransformBlockTests.cs | 208 while (await tb.OutputAvailableAsync()) in TestProducerConsumer()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Base/ |
| H A D | DataflowBlock.cs | 1432 #region OutputAvailableAsync
1446 public static Task<bool> OutputAvailableAsync<TOutput>(this ISourceBlock<TOutput> source) in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
1448 return OutputAvailableAsync<TOutput>(source, CancellationToken.None); in OutputAvailableAsync()
1468 public static Task<bool> OutputAvailableAsync<TOutput>( in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Base/ |
| H A D | DataflowBlock.cs | 1404 #region OutputAvailableAsync
1418 public static Task<bool> OutputAvailableAsync<TOutput>(this ISourceBlock<TOutput> source) in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
1420 return OutputAvailableAsync<TOutput>(source, CancellationToken.None); in OutputAvailableAsync()
1440 public static Task<bool> OutputAvailableAsync<TOutput>( in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/ref/ |
| H A D | System.Threading.Tasks.Dataflow.cs | 128 …public static System.Threading.Tasks.Task<bool> OutputAvailableAsync<TOutput>(this System.Threadin… in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
129 …public static System.Threading.Tasks.Task<bool> OutputAvailableAsync<TOutput>(this System.Threadin… in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/mono/ |
| H A D | System.Threading.Tasks.Dataflow.cs | 189 …public static System.Threading.Tasks.Task<bool> OutputAvailableAsync<TOutput>(this System.Threadin… in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
190 …public static System.Threading.Tasks.Task<bool> OutputAvailableAsync<TOutput>(this System.Threadin… in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
|
| /dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/net_4_x/ |
| H A D | System.Threading.Tasks.Dataflow.cs | 188 …public static System.Threading.Tasks.Task<bool> OutputAvailableAsync<TOutput>(this System.Threadin… in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
189 …public static System.Threading.Tasks.Task<bool> OutputAvailableAsync<TOutput>(this System.Threadin… in OutputAvailableAsync() method in System.Threading.Tasks.Dataflow.DataflowBlock
|