/dports/net/py-mpi4py/mpi4py-3.1.3/src/mpi4py/futures/ |
H A D | aplus.py | 56 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 D | mdns_client_stream.rs | 70 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 D | mdns_client_stream.rs | 70 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 D | mdns_client_stream.rs | 70 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 D | mdns_client_stream.rs | 70 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 D | Stream.pm | 95 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 D | Message.pod | 31 …: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 D | IOAsync.pm | 57 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 D | Connector.pm | 126 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 D | 19loop-future.t | 68 my $future = $loop->new_future; 77 my $future = $loop->new_future; 87 my $future = $loop->new_future;
|
H A D | 53loop-extend.t | 28 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 D | tls_client_stream.rs | 46 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 D | test_tasks.py | 91 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 D | test_tasks.py | 91 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 D | test_tasks.py | 91 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 D | test_tasks.py | 91 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 D | test_tasks.py | 91 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 D | test_tasks.py | 89 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 D | futures.py | 399 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 D | test_tasks.py | 114 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 D | futures.py | 440 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 D | Resolver.pm | 385 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 D | test_tasks.py | 102 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 D | test_tasks.py | 114 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 D | Register.pod | 33 …d>, L<is_loggedin|Protocol::XMPP::Base/is_loggedin>, L<new_future|Protocol::XMPP::Base/new_future>…
|