Home
last modified time | relevance | path

Searched refs:new_future (Results 1 – 25 of 113) sorted by relevance

12345

/dports/net/py-mpi4py/mpi4py-3.1.3/src/mpi4py/futures/
H A Daplus.py56 new_future = future.__class__()
58 _done_cb, new_future,
62 return new_future
80 def _chain_log(new_future, future): argument
84 log = registry[new_future]
87 registry[new_future] = log
100 def _chain_future(new_future, future): argument
101 _chain_log(new_future, future)
119 new_future.cancel()
122 new_future.cancel()
[all …]
/dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/trust-dns-proto-0.20.3/src/multicast/
H A Dmdns_client_stream.rs70 let new_future = Box::new(stream_future); in new() localVariable
71 let new_future = MdnsClientConnect(new_future); in new() localVariable
75 (new_future, sender) in new()
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/trust-dns-proto-0.19.5/src/multicast/
H A Dmdns_client_stream.rs70 let new_future = Box::new(stream_future); in new() localVariable
71 let new_future = MdnsClientConnect(new_future); in new() localVariable
75 (new_future, sender) in new()
/dports/net/proby/proby-1.0.2/cargo-crates/trust-dns-proto-0.18.0-alpha.2/src/multicast/
H A Dmdns_client_stream.rs70 let new_future = Box::new(stream_future); in new() localVariable
71 let new_future = MdnsClientConnect(new_future); in new() localVariable
75 (new_future, sender) in new()
/dports/net/oha/oha-0.4.7/cargo-crates/trust-dns-proto-0.20.3/src/multicast/
H A Dmdns_client_stream.rs70 let new_future = Box::new(stream_future); in new() localVariable
71 let new_future = MdnsClientConnect(new_future); in new() localVariable
75 (new_future, sender) in new()
/dports/net-im/p5-Protocol-XMPP/Protocol-XMPP-0.006/lib/Protocol/XMPP/
H A DStream.pm95 my $f = $self->new_future;
146 $self->{features_complete} ||= $self->new_future;
347 my $f = $self->new_future;
418 $self->{login_complete} ||= $self->new_future
549 $self->{remote_opened} ||= $self->new_future
554 $self->{remote_closed} ||= $self->new_future
H A DMessage.pod31 …:Base/is_loggedin>, L<new|Protocol::XMPP::Base/new>, L<new_future|Protocol::XMPP::Base/new_future>…
/dports/devel/p5-IO-Async/IO-Async-0.800/lib/Future/IO/Impl/
H A DIOAsync.pm57 my $f = $loop->new_future;
93 my $f = $loop->new_future;
124 my $f = ( $loop //= IO::Async::Loop->new )->new_future;
/dports/devel/p5-IO-Async/IO-Async-0.800/lib/IO/Async/Internals/
H A DConnector.pm126 my $f = $loop->new_future;
210 $peeraddrfuture = $loop->new_future->done( @addrs );
219 $peeraddrfuture = $loop->new_future->done(
240 …$localaddrfuture = $loop->new_future->done( exists $params{local_addrs} ? @{ $params{local_addrs} …
243 $localaddrfuture = $loop->new_future->done( {} );
/dports/devel/p5-IO-Async/IO-Async-0.800/t/
H A D19loop-future.t68 my $future = $loop->new_future;
77 my $future = $loop->new_future;
87 my $future = $loop->new_future;
H A D53loop-extend.t28 return $connect_future = $loop->new_future;
71 return $listen_future = $loop->new_future;
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/trust-dns-rustls-0.19.5/src/
H A Dtls_client_stream.rs46 let new_future = Box::pin( in tls_client_connect() localVariable
54 (new_future, sender) in tls_client_connect()
/dports/databases/py-sqlite3/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_tasks.py91 def new_future(self, loop): member in BaseTaskTests
115 fut = self.new_future(other_loop)
239 f = self.new_future(self.loop)
420 fut = self.new_future(self.loop)
508 f = self.new_future(self.loop)
523 f = self.new_future(self.loop)
645 fut = self.new_future(loop)
721 fut = self.new_future(loop)
858 fut = self.new_future(loop)
873 fut = self.new_future(loop)
[all …]
/dports/databases/py-gdbm/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_tasks.py91 def new_future(self, loop): member in BaseTaskTests
115 fut = self.new_future(other_loop)
239 f = self.new_future(self.loop)
420 fut = self.new_future(self.loop)
508 f = self.new_future(self.loop)
523 f = self.new_future(self.loop)
645 fut = self.new_future(loop)
721 fut = self.new_future(loop)
858 fut = self.new_future(loop)
873 fut = self.new_future(loop)
[all …]
/dports/lang/python-tools/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_tasks.py91 def new_future(self, loop): member in BaseTaskTests
115 fut = self.new_future(other_loop)
239 f = self.new_future(self.loop)
420 fut = self.new_future(self.loop)
508 f = self.new_future(self.loop)
523 f = self.new_future(self.loop)
645 fut = self.new_future(loop)
721 fut = self.new_future(loop)
858 fut = self.new_future(loop)
873 fut = self.new_future(loop)
[all …]
/dports/lang/python38/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_tasks.py91 def new_future(self, loop): member in BaseTaskTests
115 fut = self.new_future(other_loop)
239 f = self.new_future(self.loop)
420 fut = self.new_future(self.loop)
508 f = self.new_future(self.loop)
523 f = self.new_future(self.loop)
645 fut = self.new_future(loop)
721 fut = self.new_future(loop)
858 fut = self.new_future(loop)
873 fut = self.new_future(loop)
[all …]
/dports/x11-toolkits/py-tkinter/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_tasks.py91 def new_future(self, loop): member in BaseTaskTests
115 fut = self.new_future(other_loop)
239 f = self.new_future(self.loop)
420 fut = self.new_future(self.loop)
508 f = self.new_future(self.loop)
523 f = self.new_future(self.loop)
645 fut = self.new_future(loop)
721 fut = self.new_future(loop)
858 fut = self.new_future(loop)
873 fut = self.new_future(loop)
[all …]
/dports/lang/python37/Python-3.7.12/Lib/test/test_asyncio/
H A Dtest_tasks.py89 def new_future(self, loop): member in BaseTaskTests
114 fut = self.new_future(other_loop)
173 f_orig = self.new_future(self.loop)
384 fut = self.new_future(self.loop)
470 f = self.new_future(self.loop)
485 f = self.new_future(self.loop)
505 fut1 = self.new_future(self.loop)
604 fut = self.new_future(loop)
680 fut = self.new_future(loop)
822 fut = self.new_future(loop)
[all …]
/dports/devel/py-asyncio/asyncio-3.4.3/asyncio/
H A Dfutures.py399 new_future = Future(loop=loop)
405 new_future.add_done_callback(_check_cancel_other)
408 new_future._copy_state, future))
409 return new_future
/dports/lang/python39/Python-3.9.9/Lib/test/test_asyncio/
H A Dtest_tasks.py114 def new_future(self, loop): member in BaseTaskTests
162 fut = self.new_future(other_loop)
286 f = self.new_future(self.loop)
467 fut = self.new_future(self.loop)
707 f = self.new_future(self.loop)
722 f = self.new_future(self.loop)
844 fut = self.new_future(loop)
980 fut = self.new_future(loop)
1117 fut = self.new_future(loop)
1132 fut = self.new_future(loop)
[all …]
/dports/devel/py-trollius/trollius-2.2/trollius/
H A Dfutures.py440 new_future = Future(loop=loop)
446 new_future.add_done_callback(_check_cancel_other)
449 new_future._copy_state, future))
450 return new_future
/dports/devel/p5-IO-Async/IO-Async-0.800/lib/IO/Async/
H A DResolver.pm385 my $future = $self->loop->new_future->done( @results );
393 my $future = $self->loop->new_future->fail( $err, resolve => getaddrinfo => $err+0 );
514 my $future = $self->loop->new_future->fail( $err, resolve => getnameinfo => $err+0 );
519 my $future = $self->loop->new_future->done( $host, $service );
/dports/lang/python311/Python-3.11.0a3/Lib/test/test_asyncio/
H A Dtest_tasks.py102 def new_future(self, loop): member in BaseTaskTests
150 fut = self.new_future(other_loop)
289 f = self.new_future(self.loop)
408 fut = self.new_future(self.loop)
622 f = self.new_future(self.loop)
637 f = self.new_future(self.loop)
759 fut = self.new_future(loop)
895 fut = self.new_future(loop)
1005 fut = self.new_future(loop)
2164 fut = self.new_future(loop)
[all …]
/dports/lang/python310/Python-3.10.1/Lib/test/test_asyncio/
H A Dtest_tasks.py114 def new_future(self, loop): member in BaseTaskTests
162 fut = self.new_future(other_loop)
340 f = self.new_future(self.loop)
521 fut = self.new_future(self.loop)
761 f = self.new_future(self.loop)
776 f = self.new_future(self.loop)
898 fut = self.new_future(loop)
1034 fut = self.new_future(loop)
1144 fut = self.new_future(loop)
2545 fut = self.new_future(loop)
[all …]
/dports/net-im/p5-Protocol-XMPP/Protocol-XMPP-0.006/lib/Protocol/XMPP/Element/
H A DRegister.pod33 …d>, L<is_loggedin|Protocol::XMPP::Base/is_loggedin>, L<new_future|Protocol::XMPP::Base/new_future>…

12345