Home
last modified time | relevance | path

Searched refs:timeout_future (Results 1 – 24 of 24) sorted by relevance

/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-rtmock/tests/
H A Drtcompat_timing.rs24 let timeout_future = mock_sp.timeout(ten_min, recv); in timeouts() localVariable
25 (mock_sp, send, timeout_future) in timeouts()
30 let (mock_sp, _send, timeout_future) = setup(); in timeouts()
36 let (_, send, timeout_future) = setup(); in timeouts()
38 assert_eq!(timeout_future.await, Ok(Ok(()))); in timeouts()
42 let (mock_sp, send, timeout_future) = setup(); in timeouts()
45 assert_eq!(timeout_future.await, Ok(Ok(()))); in timeouts()
49 let (mock_sp, send, timeout_future) = setup(); in timeouts()
52 assert_eq!(timeout_future.await, Ok(Ok(()))); in timeouts()
56 let (mock_sp, _send, timeout_future) = setup(); in timeouts()
[all …]
/dports/net/pyrad/pyrad-2.4/pyrad/
H A Dclient_async.py35 self.timeout_future = None
105 self.timeout_future = asyncio.ensure_future(
148 if self.timeout_future:
149 self.timeout_future.cancel()
150 await self.timeout_future
151 self.timeout_future = None
/dports/devel/p5-IO-Async/IO-Async-0.800/t/
H A D19loop-future.t112 my $future = $loop->timeout_future( after => 1 * AUT );
120 $loop->timeout_future( after => 1 * AUT )->cancel;
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/glib-0.9.3/src/
H A Dsource_futures.rs111 pub fn timeout_future(value: u32) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
381 let res = c.block_on(timeout_future(20)); in test_timeout()
392 c.spawn(timeout_future(20).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(20).then(|()| { in test_timeout_and_channel()
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/glib-0.14.4/src/
H A Dsource_futures.rs108 pub fn timeout_future(value: Duration) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
385 c.block_on(timeout_future(Duration::from_millis(20))); in test_timeout()
394 c.spawn(timeout_future(Duration::from_millis(20)).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(Duration::from_millis(20)).then(|()| { in test_timeout_and_channel()
/dports/www/castor/castor-0.8.16/cargo-crates/glib-0.9.3/src/
H A Dsource_futures.rs111 pub fn timeout_future(value: u32) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
381 let res = c.block_on(timeout_future(20)); in test_timeout()
392 c.spawn(timeout_future(20).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(20).then(|()| { in test_timeout_and_channel()
/dports/multimedia/termplay/termplay-2.0.6/cargo-crates/glib-0.9.0/src/
H A Dsource_futures.rs111 pub fn timeout_future(value: u32) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
381 let res = c.block_on(timeout_future(20)); in test_timeout()
392 c.spawn(timeout_future(20).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(20).then(|()| { in test_timeout_and_channel()
/dports/graphics/librsvg2-rust/librsvg-2.52.8/vendor/glib/src/
H A Dsource_futures.rs108 pub fn timeout_future(value: Duration) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
385 c.block_on(timeout_future(Duration::from_millis(20))); in test_timeout()
394 c.spawn(timeout_future(Duration::from_millis(20)).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(Duration::from_millis(20)).then(|()| { in test_timeout_and_channel()
/dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/glib-0.10.3/src/
H A Dsource_futures.rs111 pub fn timeout_future(value: u32) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
381 c.block_on(timeout_future(20)); in test_timeout()
390 c.spawn(timeout_future(20).then(move |()| { in test_timeout_send()
425 let res = c.block_on(timeout_future(20).then(|()| { in test_timeout_and_channel()
/dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/glib-0.14.8/src/
H A Dsource_futures.rs108 pub fn timeout_future(value: Duration) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
385 c.block_on(timeout_future(Duration::from_millis(20))); in test_timeout()
394 c.spawn(timeout_future(Duration::from_millis(20)).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(Duration::from_millis(20)).then(|()| { in test_timeout_and_channel()
/dports/x11/squeekboard/squeekboard-d49ce45de0956432cef9b957f806d9377fee4bc0/cargo-crates/glib-0.8.2/src/
H A Dsource_futures.rs107 pub fn timeout_future(value: u32) -> Box<dyn Future<Output = ()> + std::marker::Unpin + Send> { in timeout_future() function
381 let res = c.block_on(timeout_future(20)); in test_timeout()
392 c.spawn(timeout_future(20).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(20).then(|()| { in test_timeout_and_channel()
/dports/x11/sirula/sirula-1.0.0/cargo-crates/glib-0.14.8/src/
H A Dsource_futures.rs108 pub fn timeout_future(value: Duration) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
385 c.block_on(timeout_future(Duration::from_millis(20))); in test_timeout()
394 c.spawn(timeout_future(Duration::from_millis(20)).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(Duration::from_millis(20)).then(|()| { in test_timeout_and_channel()
/dports/net-im/fractal/fractal-4.4.0/vendor/glib/src/
H A Dsource_futures.rs111 pub fn timeout_future(value: u32) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
381 let res = c.block_on(timeout_future(20)); in test_timeout()
392 c.spawn(timeout_future(20).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(20).then(|()| { in test_timeout_and_channel()
/dports/multimedia/neolink/neolink-cf54129/cargo-crates/glib-0.14.2/src/
H A Dsource_futures.rs108 pub fn timeout_future(value: Duration) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
385 c.block_on(timeout_future(Duration::from_millis(20))); in test_timeout()
394 c.spawn(timeout_future(Duration::from_millis(20)).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(Duration::from_millis(20)).then(|()| { in test_timeout_and_channel()
/dports/x11/wmfocus/wmfocus-1.2.0/cargo-crates/glib-0.14.2/src/
H A Dsource_futures.rs108 pub fn timeout_future(value: Duration) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
385 c.block_on(timeout_future(Duration::from_millis(20))); in test_timeout()
394 c.spawn(timeout_future(Duration::from_millis(20)).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(Duration::from_millis(20)).then(|()| { in test_timeout_and_channel()
/dports/sysutils/czkawka/czkawka-3.3.1/cargo-crates/glib-0.14.8/src/
H A Dsource_futures.rs108 pub fn timeout_future(value: Duration) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> { in timeout_future() function
385 c.block_on(timeout_future(Duration::from_millis(20))); in test_timeout()
394 c.spawn(timeout_future(Duration::from_millis(20)).then(move |()| { in test_timeout_send()
429 let res = c.block_on(timeout_future(Duration::from_millis(20)).then(|()| { in test_timeout_and_channel()
/dports/devel/sccache/sccache-0.2.15/cargo-crates/gloo-timers-0.2.1/tests/
H A Dweb.rs52 async fn timeout_future() { in timeout_future() function
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/gloo-timers-0.2.1/tests/
H A Dweb.rs52 async fn timeout_future() { in timeout_future() function
/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/gloo-timers-0.2.1/tests/
H A Dweb.rs52 async fn timeout_future() { in timeout_future() function
/dports/textproc/jql/jql-3.0.6/cargo-crates/gloo-timers-0.2.2/tests/
H A Dweb.rs52 async fn timeout_future() { in timeout_future() function
/dports/sysutils/py-salt/salt-3004.1/salt/netapi/rest_tornado/
H A Dsaltnado.py357 timeout_future = salt.ext.tornado.ioloop.IOLoop.current().call_later(
360 self.timeout_map[future] = timeout_future
/dports/www/p5-Net-Async-HTTP/Net-Async-HTTP-0.48/lib/Net/Async/
H A DHTTP.pm983 $self->loop->timeout_future( after => $timeout )
/dports/devel/p5-IO-Async/IO-Async-0.800/lib/IO/Async/
H A DLoop.pm719 sub timeout_future subroutine
/dports/devel/p5-IO-Async/IO-Async-0.800/
H A DChanges332 * Added $loop->delay_future and $loop->timeout_future