| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/util/ |
| H A D | future_test.cc | 430 auto fut2 = in TEST() local
433 ref2 = fut2.impl_; in TEST()
442 ref2 = fut2.impl_; in TEST()
459 ref2 = fut2.impl_; in TEST()
595 auto fut2 = in TEST() local
606 AssertFailed(fut2); in TEST()
625 AssertFailed(fut2); in TEST()
667 AssertFailed(fut2); in TEST()
733 AssertFailed(fut2); in TEST()
785 AssertFailed(fut2); in TEST()
[all …]
|
| /dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/util/ |
| H A D | future_test.cc | 356 ref2 = fut2.impl_; in TEST()
365 ref2 = fut2.impl_; in TEST()
382 ref2 = fut2.impl_; in TEST()
533 auto fut2 = in TEST() local
544 AssertFailed(fut2); in TEST()
563 AssertFailed(fut2); in TEST()
605 AssertFailed(fut2); in TEST()
671 AssertFailed(fut2); in TEST()
723 AssertFailed(fut2); in TEST()
750 AssertFailed(fut2); in TEST()
[all …]
|
| /dports/databases/py-aioredis/aioredis-1.3.1/tests/ |
| H A D | transaction_commands_test.py | 60 fut2 = tr.incrby('foo', 1.0)
66 assert fut2.done() is True
72 assert not fut2.cancelled()
100 await fut2
141 await fut2
148 fut2 = tr.incr('foo')
153 await fut2
187 res = await fut2
209 res = await fut2
231 fut2 = tr.get('bar')
[all …]
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/async-std-1.8.0/src/future/future/ |
| H A D | flatten.rs | 27 fut2: Fut2,
53 let fut2 = ready!(fut1.poll(cx)).into_future(); in poll() localVariable
54 state.set(State::Second { fut2 }); in poll()
56 StateProj::Second { fut2 } => { in poll()
57 let v = ready!(fut2.poll(cx)); in poll()
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/async-std-1.10.0/src/future/future/ |
| H A D | flatten.rs | 27 fut2: Fut2,
53 let fut2 = ready!(fut1.poll(cx)).into_future(); in poll() localVariable
54 state.set(State::Second { fut2 }); in poll()
56 StateProj::Second { fut2 } => { in poll()
57 let v = ready!(fut2.poll(cx)); in poll()
|
| /dports/textproc/jql/jql-3.0.6/cargo-crates/async-std-1.10.0/src/future/future/ |
| H A D | flatten.rs | 27 fut2: Fut2,
53 let fut2 = ready!(fut1.poll(cx)).into_future(); in poll() localVariable
54 state.set(State::Second { fut2 }); in poll()
56 StateProj::Second { fut2 } => { in poll()
57 let v = ready!(fut2.poll(cx)); in poll()
|
| /dports/databases/py-aioredis/aioredis-1.3.1/examples/ |
| H A D | pipeline.py | 18 fut2 = redis.incr('bar') # issue command and return future
20 val, cnt = await asyncio.gather(fut1, fut2)
27 fut2 = pipe.incr('bar')
29 val, cnt = await asyncio.gather(fut1, fut2)
|
| /dports/games/genact/genact-0.10.0/cargo-crates/async-std-1.6.3/src/future/future/ |
| H A D | flatten.rs | 40 let fut2 = ready!(unsafe { Pin::new_unchecked(fut1) }.poll(cx)).into_future(); in poll() localVariable
41 *state = State::Second(fut2); in poll()
43 State::Second(fut2) => { in poll()
44 let v = ready!(unsafe { Pin::new_unchecked(fut2) }.poll(cx)); in poll()
|
| /dports/security/rustscan/RustScan-2.0.1/cargo-crates/async-std-1.7.0/src/future/future/ |
| H A D | flatten.rs | 40 let fut2 = ready!(unsafe { Pin::new_unchecked(fut1) }.poll(cx)).into_future(); in poll() localVariable
41 *state = State::Second(fut2); in poll()
43 State::Second(fut2) => { in poll()
44 let v = ready!(unsafe { Pin::new_unchecked(fut2) }.poll(cx)); in poll()
|
| /dports/lang/nim/nim-1.6.2/tests/async/ |
| H A D | tawaitsemantics.nim | 31 var fut2 = dummy()
32 await fut or fut2 # Should raise!
37 var fut2 = dummy()
38 await fut and fut2 # Should raise!
43 var fut2 = dummy()
44 await all(fut, fut2) # Should raise!
|
| /dports/multimedia/termplay/termplay-2.0.6/cargo-crates/futures-util-0.3.1/src/future/future/ |
| H A D | chain.rs | 47 Chain::Second(fut2) => { in poll()
48 return unsafe { Pin::new_unchecked(fut2) }.poll(cx); in poll()
54 let fut2 = (f.take().unwrap())(output, data); in poll() localVariable
55 *this = Chain::Second(fut2) in poll()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-util-preview-0.3.0-alpha.19/src/future/ |
| H A D | chain.rs | 47 Chain::Second(fut2) => { in poll()
48 return unsafe { Pin::new_unchecked(fut2) }.poll(cx); in poll()
54 let fut2 = (f.take().unwrap())(output, data); in poll() localVariable
55 *this = Chain::Second(fut2) in poll()
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/futures-util-preview-0.3.0-alpha.19/src/future/ |
| H A D | chain.rs | 47 Chain::Second(fut2) => { in poll()
48 return unsafe { Pin::new_unchecked(fut2) }.poll(cx); in poll()
54 let fut2 = (f.take().unwrap())(output, data); in poll() localVariable
55 *this = Chain::Second(fut2) in poll()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/futures-util/src/future/future/ |
| H A D | chain.rs | 47 Chain::Second(fut2) => { in poll()
48 return unsafe { Pin::new_unchecked(fut2) }.poll(cx); in poll()
54 let fut2 = (f.take().unwrap())(output, data); in poll() localVariable
55 *this = Chain::Second(fut2) in poll()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/futures-util-0.3.4/src/future/future/ |
| H A D | chain.rs | 47 Chain::Second(fut2) => { in set_fixed_execution_hash_seed()
48 return unsafe { Pin::new_unchecked(fut2) }.poll(cx); in set_fixed_execution_hash_seed()
54 let fut2 = (f.take().unwrap())(output, data); in set_fixed_execution_hash_seed()
55 *this = Chain::Second(fut2) in set_fixed_execution_hash_seed()
|
| /dports/devel/py-asynctest/asynctest-0.13.0/test/ |
| H A D | test_helpers.py | 30 fut2 = asyncio.Future(loop=self.loop)
32 fut.add_done_callback(lambda _: fut2.set_result(None))
36 self.assertTrue(fut2.done())
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/util/ |
| H A D | future_test.cpp | 331 auto fut2 = std::move(fut).then( in TEST() local
342 auto fut2 = std::move(fut).then( in TEST() local
465 ASSERT_EQ(fut2.getNoThrow(), ErrorCodes::BadValue); in TEST()
471 auto fut2 = std::move(fut).onError([](Status s) { in TEST() local
475 ASSERT_EQ(fut2.getNoThrow(), ErrorCodes::BadValue); in TEST()
812 auto fut2 = std::move(fut).then( in TEST() local
911 auto fut2 = std::move(fut).onError([](Status s) { in TEST() local
915 ASSERT_EQ(fut2.getNoThrow(), ErrorCodes::BadValue); in TEST()
921 auto fut2 = std::move(fut).onError([](Status s) { in TEST() local
1277 auto fut2 = std::move(fut).then( in TEST() local
[all …]
|
| /dports/multimedia/termplay/termplay-2.0.6/cargo-crates/futures-util-0.3.1/src/future/try_future/ |
| H A D | try_chain.rs | 56 TryChain::Second(fut2) => { in poll()
58 return unsafe { Pin::new_unchecked(fut2) } in poll()
73 TryChainAction::Future(fut2) => *this = TryChain::Second(fut2), in poll()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-util-preview-0.3.0-alpha.19/src/try_future/ |
| H A D | try_chain.rs | 56 TryChain::Second(fut2) => { in poll()
58 return unsafe { Pin::new_unchecked(fut2) } in poll()
73 TryChainAction::Future(fut2) => *this = TryChain::Second(fut2), in poll()
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/futures-util-preview-0.3.0-alpha.19/src/try_future/ |
| H A D | try_chain.rs | 56 TryChain::Second(fut2) => { in poll()
58 return unsafe { Pin::new_unchecked(fut2) } in poll()
73 TryChainAction::Future(fut2) => *this = TryChain::Second(fut2), in poll()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/futures-util/src/future/try_future/ |
| H A D | try_chain.rs | 56 TryChain::Second(fut2) => { in poll()
58 return unsafe { Pin::new_unchecked(fut2) } in poll()
73 TryChainAction::Future(fut2) => *this = TryChain::Second(fut2), in poll()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/futures-util-0.3.4/src/future/try_future/ |
| H A D | try_chain.rs | 56 TryChain::Second(fut2) => { in poll()
58 return unsafe { Pin::new_unchecked(fut2) } in poll()
73 TryChainAction::Future(fut2) => *this = TryChain::Second(fut2), in poll()
|
| /dports/devel/folly/folly-2021.12.27.00/folly/experimental/coro/test/ |
| H A D | FutureUtilTest.cpp | 93 auto fut2 = folly::coro::toFuture(gen.next(), &ex); in TEST() local
94 EXPECT_FALSE(fut2.isReady()); in TEST()
96 EXPECT_TRUE(fut2.isReady()); in TEST()
97 EXPECT_EQ(*std::move(fut2).get(), 42); in TEST()
|
| /dports/misc/glow/glow-f24d960e3cc80db95ac0bc17b1900dbf60ca044a/tests/unittests/ |
| H A D | ThreadPoolTest.cpp | 95 auto fut2 = ex->submit([&t2]() { t2 = std::this_thread::get_id(); }); in TEST() local
98 fut2.get(); in TEST()
108 fut2 = ex2->submit([&t2] { t2 = std::this_thread::get_id(); }); in TEST()
111 fut2.get(); in TEST()
|
| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/tokio-util-0.6.7/tests/ |
| H A D | reusable_box.rs | 33 let fut2 = async move { val[0] }; in test_different_sizes() localVariable
37 assert_eq!(Layout::for_value(&fut2).size(), 4004); in test_different_sizes()
42 b.set(fut2); in test_different_sizes()
|