| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/ |
| H A D | Observable.Awaiter.cs | 53 …public static AsyncSubject<TSource> RunAsync<TSource>(this IObservable<TSource> source, Cancellati… in RunAsync() method in System.Reactive.Linq.Observable
58 return s_impl.RunAsync<TSource>(source, cancellationToken); in RunAsync()
70 …public static AsyncSubject<TSource> RunAsync<TSource>(this IConnectableObservable<TSource> source,… in RunAsync() method in System.Reactive.Linq.Observable
75 return s_impl.RunAsync<TSource>(source, cancellationToken); in RunAsync()
|
| H A D | QueryLanguage.Awaiter.cs | 15 return RunAsync<TSource>(source, CancellationToken.None); in GetAwaiter()
20 return RunAsync<TSource>(source, CancellationToken.None); in GetAwaiter()
23 …public virtual AsyncSubject<TSource> RunAsync<TSource>(IObservable<TSource> source, CancellationTo… in RunAsync() method in System.Reactive.Linq.QueryLanguage
42 …public virtual AsyncSubject<TSource> RunAsync<TSource>(IConnectableObservable<TSource> source, Can… in RunAsync() method in System.Reactive.Linq.QueryLanguage
|
| /dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/internal/ |
| H A D | background_threads_impl_test.cc | 47 cq.RunAsync([&bg] { bg.set_value(std::this_thread::get_id()); }); in TEST()
80 actual.cq().RunAsync([&bg] { bg.set_value(std::this_thread::get_id()); }); in TEST()
90 actual.cq().RunAsync([&bg] { bg.set_value(std::this_thread::get_id()); }); in TEST()
102 actual.cq().RunAsync([&p] { p.set_value(std::this_thread::get_id()); }); in TEST()
119 actual.cq().RunAsync([&p] { p.set_value(); }); in TEST()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/sync/engine_impl/ |
| H A D | cancelation_signal_unittest.cc | 24 void RunAsync(base::WaitableEvent* task_start_signal,
63 void BlockingTask::RunAsync(base::WaitableEvent* task_start_signal, in RunAsync() function in syncer::BlockingTask
132 blocking_task_.RunAsync(&task_start_event_, &task_done_event_); in StartBlockingTaskAsync()
136 blocking_task_.RunAsync(&task_start_event_, &task_done_event_); in StartBlockingTaskAndWaitForItToStart()
|
| /dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/internal/ |
| H A D | background_threads_impl_test.cc | 47 cq.RunAsync([&bg] { bg.set_value(std::this_thread::get_id()); }); in TEST()
80 actual.cq().RunAsync([&bg] { bg.set_value(std::this_thread::get_id()); }); in TEST()
90 actual.cq().RunAsync([&bg] { bg.set_value(std::this_thread::get_id()); }); in TEST()
102 actual.cq().RunAsync([&p] { p.set_value(std::this_thread::get_id()); }); in TEST()
|
| /dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/ |
| H A D | completion_queue_test.cc | 374 TEST(CompletionQueueTest, RunAsync) { in TEST() argument
410 cq.RunAsync([&done_promise](CompletionQueue& cq) { in TEST()
432 cq.RunAsync(MoveOnly{std::move(p)}); in TEST()
450 cq.RunAsync(MoveOnly{std::move(p)}); in TEST()
480 cq.RunAsync( in TEST()
509 cq.RunAsync(on_run_async); in TEST()
560 cq.RunAsync(on_run_async); in TEST()
576 cq.RunAsync([&] { in TEST()
583 cq.RunAsync([&c] { c.set_value(); }); in TEST()
624 cq.RunAsync(on_async); in TEST_P()
[all …]
|
| H A D | completion_queue.h | 190 void RunAsync(Functor&& functor) { in RunAsync() function
207 impl_->RunAsync( in RunAsync()
221 void RunAsync(Functor&& functor) { in RunAsync() function
231 impl_->RunAsync(absl::make_unique<Wrapper>(std::forward<Functor>(functor))); in RunAsync()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/tests/ |
| H A D | test-debug-19.cs | 12 await RunAsync (); in Test_1()
15 static Task RunAsync () in RunAsync() method in C
|
| H A D | test-async-01.cs | 37 await RunAsync ().ConfigureAwait (false); in TestAsync()
46 static Task RunAsync () in RunAsync() method in Program
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/devil/devil/utils/ |
| H A D | reraiser_thread_unittest.py | 106 results = reraiser_thread.RunAsync([])
110 results = reraiser_thread.RunAsync([lambda: 1])
114 a, b = reraiser_thread.RunAsync((lambda: 1, lambda: 2))
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/ |
| H A D | TestBase.cs | 14 public void RunAsync(Action<Waiter> a) in RunAsync() method in ReactiveTests.TestBase
51 public void RunAsync(Action<Waiter> a)
|
| /dports/lang/mono-basic/mono-basic-4.7/vbnc/rt/source/ |
| H A D | TestExecutor.vb | 151 Sub RunAsync(ByVal Test As Test, Optional ByVal Priority As Boolean = False)
182 …Sub RunAsync(ByVal Tests As Generic.IEnumerable(Of Test), Optional ByVal Priority As Boolean = Fal…
207 RunAsync(Tests.Values)
|
| /dports/games/libretro-genesis_plus_gx/Genesis-Plus-GX-7f83bc5/libretro/uwp/ |
| H A D | uwp_async.h | 38 T RunAsync(std::function<concurrency::task<T>()> func) in RunAsync() function
75 return RunAsync<T>(func); in RunAsyncAndCatchErrors()
|
| /dports/games/retroarch/RetroArch-1.9.7/uwp/ |
| H A D | uwp_async.h | 40 T RunAsync(std::function<concurrency::task<T>()> func) in RunAsync() function
77 return RunAsync<T>(func); in RunAsyncAndCatchErrors()
|
| /dports/games/kodi-addon-game.libretro.genplus/game.libretro.genplus-1.7.4.15-Matrix/depends/common/genplus/libretro/uwp/ |
| H A D | uwp_async.h | 38 T RunAsync(std::function<concurrency::task<T>()> func) in RunAsync() function
75 return RunAsync<T>(func); in RunAsyncAndCatchErrors()
|
| /dports/devel/msbuild/msbuild-0.06/src/Xunit.NetCore.Extensions/ |
| H A D | SkippedTestCase.cs | 45 public Task<RunSummary> RunAsync( in RunAsync() method in Xunit.NetCore.Extensions.SkippedTestCase
49 …tructorArguments, TestMethodArguments, messageBus, aggregator, cancellationTokenSource).RunAsync(); in RunAsync()
|
| /dports/net/pjsip/pjproject-2.11.1/pjsip-apps/src/pjsua/winrt/gui/uwp/Voip/Helpers/ |
| H A D | AppServiceHelper.cs | 112 …await CoreApplication.MainView.CoreWindow.Dispatcher.RunAsync(CoreDispatcherPriority.Normal, () =>… in Connection_RequestReceived()
124 …await CoreApplication.MainView.CoreWindow.Dispatcher.RunAsync(CoreDispatcherPriority.Normal, () =>… in Connection_RequestReceived()
136 …await CoreApplication.MainView.CoreWindow.Dispatcher.RunAsync(CoreDispatcherPriority.Normal, () =>… in Connection_RequestReceived()
|
| /dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/ |
| H A D | completion_queue_test.cc | 325 TEST(CompletionQueueTest, RunAsync) { in TEST() argument
331 cq.RunAsync([&done_promise](CompletionQueue&) { done_promise.set_value(); }); in TEST()
346 cq.RunAsync([&done_promise] { done_promise.set_value(); }); in TEST()
361 cq.RunAsync([&done_promise](CompletionQueue& cq) { in TEST()
383 cq.RunAsync(MoveOnly{std::move(p)}); in TEST()
401 cq.RunAsync(MoveOnly{std::move(p)}); in TEST()
431 cq.RunAsync( in TEST()
|
| /dports/devel/grpc/grpc-1.42.0/src/csharp/Grpc.IntegrationTesting/ |
| H A D | QpsWorker.cs | 60 workerServer.RunAsync().Wait(); in Run()
64 private async Task RunAsync() in RunAsync() method in Grpc.IntegrationTesting.QpsWorker
|
| /dports/devel/grpc130/grpc-1.30.2/src/csharp/Grpc.IntegrationTesting/ |
| H A D | QpsWorker.cs | 60 workerServer.RunAsync().Wait(); in Run()
64 private async Task RunAsync() in RunAsync() method in Grpc.IntegrationTesting.QpsWorker
|
| /dports/devel/grpc134/grpc-1.34.1/src/csharp/Grpc.IntegrationTesting/ |
| H A D | QpsWorker.cs | 60 workerServer.RunAsync().Wait(); in Run()
64 private async Task RunAsync() in RunAsync() method in Grpc.IntegrationTesting.QpsWorker
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/csharp/Grpc.IntegrationTesting/ |
| H A D | QpsWorker.cs | 60 workerServer.RunAsync().Wait(); in Run()
64 private async Task RunAsync() in RunAsync() method in Grpc.IntegrationTesting.QpsWorker
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/browser/api/ |
| H A D | async_api_function.cc | 22 bool AsyncApiFunction::RunAsync() { in RunAsync() function in extensions::AsyncApiFunction
51 if (RunAsync()) in Run()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/extensions/browser/api/ |
| H A D | async_api_function.cc | 24 bool AsyncApiFunction::RunAsync() { in RunAsync() function in extensions::AsyncApiFunction
53 if (RunAsync()) in Run()
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/tutorial/netcore/Server/ |
| H A D | Program.cs | 57 RunAsync(args, source.Token).GetAwaiter().GetResult(); in Main()
98 private static async Task RunAsync(string[] args, CancellationToken cancellationToken) in RunAsync() method in Server.Program
292 host.RunAsync(cancellationToken).GetAwaiter().GetResult(); in Run()
|