/dports/www/p5-Net-Async-HTTP/Net-Async-HTTP-0.48/t/ |
H A D | 81cross-https.t | 7 use IO::Async::Test; 8 use IO::Async::Loop; 10 use IO::Async::Stream; 12 unless( eval { require Net::Async::HTTP::Server and 13 Net::Async::HTTP::Server->VERSION( '0.06' ) } ) { 16 unless( eval { require Net::Async::HTTP } ) { 19 unless( eval { require IO::Async::SSL and 20 IO::Async::SSL->VERSION( '0.12' ) } ) { 26 my $loop = IO::Async::Loop->new(); 29 my $server = Net::Async::HTTP::Server->new( [all …]
|
/dports/devel/folly/folly-2021.12.27.00/folly/fibers/async/test/ |
H A D | AsyncTest.cpp | 41 async::Async<void> getAsyncNothing() { in getAsyncNothing() 44 async::Async<std::string> getAsyncString() { in getAsyncString() 211 static_assert(async::is_async_v<async::Async<int>>); in TEST() 220 auto getLiteral = []() { return async::Async(1); }; in TEST() 234 return async::Async(static_cast<const int&>(i)); in TEST() 253 [&]() -> async::Async<void> { in TEST() 291 [&]() -> async::Async<void> { in TEST() 305 return [&]() -> async::Async<void> { in TEST() 311 return [=]() -> async::Async<int> { return val; }; in TEST() 359 [&]() -> async::Async<void> { in TEST() [all …]
|
/dports/devel/p5-Gearman-Client-Async/Gearman-Client-Async-0.94/lib/Gearman/Client/Async/ |
H A D | Connection.pm | 1 package Gearman::Client::Async::Connection; 38 my Gearman::Client::Async::Connection $self = shift; 80 my Gearman::Client::Async::Connection $self = shift; 85 my Gearman::Client::Async::Connection $self = shift; 91 my Gearman::Client::Async::Connection $self = shift; 134 my Gearman::Client::Async::Connection $self = shift; 148 my Gearman::Client::Async::Connection $self = shift; 154 my Gearman::Client::Async::Connection $self = shift; 167 my Gearman::Client::Async::Connection $self = shift; 182 my Gearman::Client::Async::Connection $self = shift; [all …]
|
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-core-0.1.17/src/reactor/ |
H A D | poll_evented.rs | 14 use futures::{task, Async, Poll}; 138 pub fn poll_read(&self) -> Async<()> { in poll_read() argument 143 Async::NotReady in poll_read() 146 fn poll_read2(&self) -> Async<Ready> { in poll_read2() 162 Async::Ready(r) => r, in poll_read2() 163 _ => return Async::NotReady, in poll_read2() 186 pub fn poll_write(&self) -> Async<()> { in poll_write() argument 201 Async::Ready(r) => r, in poll_write() 202 _ => return Async::NotReady, in poll_write() 264 Async::NotReady in poll_ready() [all …]
|
/dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/tokio-core-0.1.17/src/reactor/ |
H A D | poll_evented.rs | 14 use futures::{task, Async, Poll}; 138 pub fn poll_read(&self) -> Async<()> { in poll_read() argument 143 Async::NotReady in poll_read() 146 fn poll_read2(&self) -> Async<Ready> { in poll_read2() 162 Async::Ready(r) => r, in poll_read2() 163 _ => return Async::NotReady, in poll_read2() 186 pub fn poll_write(&self) -> Async<()> { in poll_write() argument 201 Async::Ready(r) => r, in poll_write() 202 _ => return Async::NotReady, in poll_write() 264 Async::NotReady in poll_ready() [all …]
|
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-core-0.1.17/src/reactor/ |
H A D | poll_evented.rs | 14 use futures::{task, Async, Poll}; 138 pub fn poll_read(&self) -> Async<()> { in poll_read() argument 143 Async::NotReady in poll_read() 146 fn poll_read2(&self) -> Async<Ready> { in poll_read2() 162 Async::Ready(r) => r, in poll_read2() 163 _ => return Async::NotReady, in poll_read2() 186 pub fn poll_write(&self) -> Async<()> { in poll_write() argument 201 Async::Ready(r) => r, in poll_write() 202 _ => return Async::NotReady, in poll_write() 264 Async::NotReady in poll_ready() [all …]
|
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/librespot-core-0.1.2/src/ |
H A D | channel.rs | 4 use futures::{Async, Poll, Stream}; 106 Ok(Async::Ready(Some(t))) => t, in recv_packet() 108 Ok(Async::NotReady) => return Ok(Async::NotReady), in recv_packet() 120 Ok(Async::Ready(packet)) in recv_packet() 155 return Ok(Async::Ready(Some(event))); in poll() 164 return Ok(Async::Ready(None)); in poll() 181 Async::Ready(c) => c, in poll() 182 Async::NotReady => return Ok(Async::NotReady), in poll() 189 None => return Ok(Async::Ready(None)), in poll() 201 Async::Ready(c) => c, in poll() [all …]
|
/dports/lang/spidermonkey60/firefox-60.9.0/third_party/rust/tokio-core/src/reactor/ |
H A D | poll_evented.rs | 13 use futures::{Async, Poll}; 101 pub fn poll_read(&self) -> Async<()> { in poll_read() argument 103 return Async::Ready(()) in poll_read() 107 Async::Ready(()) in poll_read() 110 Async::NotReady in poll_read() 121 pub fn poll_write(&self) -> Async<()> { in poll_write() argument 123 return Async::Ready(()) in poll_write() 127 Async::Ready(()) in poll_write() 130 Async::NotReady in poll_write() 241 fn poll_read(&mut self) -> Async<()> { in poll_read() argument [all …]
|
/dports/multimedia/librespot/librespot-0.1.3/core/src/ |
H A D | channel.rs | 4 use futures::{Async, Poll, Stream}; 106 Ok(Async::Ready(Some(t))) => t, in recv_packet() 108 Ok(Async::NotReady) => return Ok(Async::NotReady), in recv_packet() 120 Ok(Async::Ready(packet)) in recv_packet() 155 return Ok(Async::Ready(Some(event))); in poll() 164 return Ok(Async::Ready(None)); in poll() 181 Async::Ready(c) => c, in poll() 182 Async::NotReady => return Ok(Async::NotReady), in poll() 189 None => return Ok(Async::Ready(None)), in poll() 201 Async::Ready(c) => c, in poll() [all …]
|
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/librespot-core-0.1.1/src/ |
H A D | channel.rs | 4 use futures::{Async, Poll, Stream}; 106 Ok(Async::Ready(Some(t))) => t, in recv_packet() 108 Ok(Async::NotReady) => return Ok(Async::NotReady), in recv_packet() 120 Ok(Async::Ready(packet)) in recv_packet() 155 return Ok(Async::Ready(Some(event))); in poll() 164 return Ok(Async::Ready(None)); in poll() 181 Async::Ready(c) => c, in poll() 182 Async::NotReady => return Ok(Async::NotReady), in poll() 189 None => return Ok(Async::Ready(None)), in poll() 201 Async::Ready(c) => c, in poll() [all …]
|
/dports/devel/p5-IO-Async/IO-Async-0.800/t/ |
H A D | 25socket.t | 6 use IO::Async::Test; 16 use IO::Async::Loop; 18 use IO::Async::OS; 20 use IO::Async::Socket; 22 my $loop = IO::Async::Loop->new_builtin; 53 my $socket = IO::Async::Socket->new( 119 my $socket = IO::Async::Socket->new( 214 my $socket = IO::Async::Socket->new( 264 my ( $ES1, $ES2 ) = IO::Async::OS->socketpair or die "Cannot socketpair - $!"; 276 my $socket = IO::Async::Socket->new( [all …]
|
H A D | 33process.t | 6 use IO::Async::Test; 14 use IO::Async::Process; 16 use IO::Async::Loop; 17 use IO::Async::OS; 21 my $loop = IO::Async::Loop->new_builtin; 28 my $process = IO::Async::Process->new( 78 my $process = IO::Async::Process->new( 92 my $process = IO::Async::Process->new( 108 my $process = IO::Async::Process->new( 139 my $process = IO::Async::Process->new( [all …]
|
H A D | 61protocol-stream.t | 6 use IO::Async::Test; 11 use IO::Async::Loop; 13 use IO::Async::OS; 15 use IO::Async::Stream; 16 use IO::Async::Protocol::Stream; 21 my $loop = IO::Async::Loop->new_builtin; 34 my $streamproto = IO::Async::Protocol::Stream->new( 35 transport => IO::Async::Stream->new( handle => $S1 ), 137 transport => IO::Async::Stream->new( handle => $S1 ), 175 my $streamproto = IO::Async::Protocol::Stream->new( [all …]
|
/dports/devel/sccache/sccache-0.2.15/cargo-crates/async-io-1.3.1/tests/ |
H A D | async.rs | 10 use async_io::{Async, Timer}; 43 let stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_connect() 69 let mut stream = Async::<TcpStream>::connect(addr).await?; in tcp_peek_read() 92 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_reader_hangup() 114 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_writer_hangup() 165 let listener = Async::<UnixListener>::bind(&path)?; in udp_connect() 187 let listener = Async::<UnixListener>::bind(&path)?; in uds_connect() 218 let (socket1, socket2) = Async::<UnixDatagram>::pair()?; in uds_send_recv() 235 let socket1 = Async::<UnixDatagram>::bind(&path)?; in uds_send_to_recv_from() 236 let socket2 = Async::<UnixDatagram>::unbound()?; in uds_send_to_recv_from() [all …]
|
/dports/games/genact/genact-0.10.0/cargo-crates/async-io-0.1.11/tests/ |
H A D | async.rs | 10 use async_io::{Async, Timer}; 43 let stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_connect() 69 let mut stream = Async::<TcpStream>::connect(addr).await?; in tcp_peek_read() 92 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_reader_hangup() 114 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_writer_hangup() 165 let listener = Async::<UnixListener>::bind(&path)?; in udp_connect() 187 let listener = Async::<UnixListener>::bind(&path)?; in uds_connect() 218 let (socket1, socket2) = Async::<UnixDatagram>::pair()?; in uds_send_recv() 235 let socket1 = Async::<UnixDatagram>::bind(&path)?; in uds_send_to_recv_from() 236 let socket2 = Async::<UnixDatagram>::unbound()?; in uds_send_to_recv_from() [all …]
|
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/async-io-1.1.10/tests/ |
H A D | async.rs | 10 use async_io::{Async, Timer}; 43 let stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_connect() 69 let mut stream = Async::<TcpStream>::connect(addr).await?; in tcp_peek_read() 92 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_reader_hangup() 114 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_writer_hangup() 165 let listener = Async::<UnixListener>::bind(&path)?; in udp_connect() 187 let listener = Async::<UnixListener>::bind(&path)?; in uds_connect() 218 let (socket1, socket2) = Async::<UnixDatagram>::pair()?; in uds_send_recv() 235 let socket1 = Async::<UnixDatagram>::bind(&path)?; in uds_send_to_recv_from() 236 let socket2 = Async::<UnixDatagram>::unbound()?; in uds_send_to_recv_from() [all …]
|
/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/async-io-1.6.0/tests/ |
H A D | async.rs | 10 use async_io::{Async, Timer}; 43 let stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_connect() 69 let mut stream = Async::<TcpStream>::connect(addr).await?; in tcp_peek_read() 92 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_reader_hangup() 114 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_writer_hangup() 165 let listener = Async::<UnixListener>::bind(&path)?; in udp_connect() 187 let listener = Async::<UnixListener>::bind(&path)?; in uds_connect() 218 let (socket1, socket2) = Async::<UnixDatagram>::pair()?; in uds_send_recv() 235 let socket1 = Async::<UnixDatagram>::bind(&path)?; in uds_send_to_recv_from() 236 let socket2 = Async::<UnixDatagram>::unbound()?; in uds_send_to_recv_from() [all …]
|
/dports/textproc/jql/jql-3.0.6/cargo-crates/async-io-1.6.0/tests/ |
H A D | async.rs | 10 use async_io::{Async, Timer}; 43 let stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_connect() 69 let mut stream = Async::<TcpStream>::connect(addr).await?; in tcp_peek_read() 92 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_reader_hangup() 114 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_writer_hangup() 165 let listener = Async::<UnixListener>::bind(&path)?; in udp_connect() 187 let listener = Async::<UnixListener>::bind(&path)?; in uds_connect() 218 let (socket1, socket2) = Async::<UnixDatagram>::pair()?; in uds_send_recv() 235 let socket1 = Async::<UnixDatagram>::bind(&path)?; in uds_send_to_recv_from() 236 let socket2 = Async::<UnixDatagram>::unbound()?; in uds_send_to_recv_from() [all …]
|
/dports/audio/ncspot/ncspot-0.9.3/cargo-crates/async-io-1.6.0/tests/ |
H A D | async.rs | 10 use async_io::{Async, Timer}; 43 let stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_connect() 69 let mut stream = Async::<TcpStream>::connect(addr).await?; in tcp_peek_read() 92 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_reader_hangup() 114 let mut stream2 = Async::<TcpStream>::connect(addr).await?; in tcp_writer_hangup() 165 let listener = Async::<UnixListener>::bind(&path)?; in udp_connect() 187 let listener = Async::<UnixListener>::bind(&path)?; in uds_connect() 218 let (socket1, socket2) = Async::<UnixDatagram>::pair()?; in uds_send_recv() 235 let socket1 = Async::<UnixDatagram>::bind(&path)?; in uds_send_to_recv_from() 236 let socket2 = Async::<UnixDatagram>::unbound()?; in uds_send_to_recv_from() [all …]
|
/dports/lang/spidermonkey60/firefox-60.9.0/third_party/rust/futures/benches/ |
H A D | sync_mpsc.rs | 6 use futures::{Async, Poll, AsyncSink}; 46 assert_eq!(Ok(Async::NotReady), rx.poll_stream_notify(¬ify_noop(), 1)); in unbounded_1_tx() 51 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll_stream_notify(¬ify_noop(), 1)); in unbounded_1_tx() 69 assert_eq!(Ok(Async::NotReady), rx.poll_stream_notify(¬ify_noop(), 1)); in unbounded_100_tx() 73 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll_stream_notify(¬ify_noop(), 1)); in unbounded_100_tx() 87 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll()); in unbounded_uncontended() 109 assert_eq!(Ok(Async::Ready(())), self.tx.poll_complete()); in poll() 110 Ok(Async::Ready(Some(self.last))) in poll() 113 Ok(Async::NotReady) in poll() 135 assert_eq!(Ok(Async::NotReady), tx.poll_stream_notify(¬ify_noop(), 1)); in bounded_1_tx() [all …]
|
/dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/futures-0.1.23/benches/ |
H A D | sync_mpsc.rs | 6 use futures::{Async, Poll, AsyncSink}; 46 assert_eq!(Ok(Async::NotReady), rx.poll_stream_notify(¬ify_noop(), 1)); in unbounded_1_tx() 51 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll_stream_notify(¬ify_noop(), 1)); in unbounded_1_tx() 69 assert_eq!(Ok(Async::NotReady), rx.poll_stream_notify(¬ify_noop(), 1)); in unbounded_100_tx() 73 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll_stream_notify(¬ify_noop(), 1)); in unbounded_100_tx() 87 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll()); in unbounded_uncontended() 109 assert_eq!(Ok(Async::Ready(())), self.tx.poll_complete()); in poll() 110 Ok(Async::Ready(Some(self.last))) in poll() 113 Ok(Async::NotReady) in poll() 135 assert_eq!(Ok(Async::NotReady), tx.poll_stream_notify(¬ify_noop(), 1)); in bounded_1_tx() [all …]
|
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/hyper-0.11.27/src/proto/h1/ |
H A D | decode.rs | 6 use futures::{Async, Poll}; 104 Ok(Async::Ready(buf)) in decode() 130 Ok(Async::Ready(slice)) in decode() 210 Ok(Async::Ready(ChunkedState::Size)) in read_size() 325 use futures::{Async, Poll}; 346 impl HelpUnwrap<Bytes> for Async<Bytes> { implementation 349 Async::Ready(bytes) => bytes, in unwrap() 350 Async::NotReady => panic!(), in unwrap() 358 Async::NotReady => panic!(), in unwrap() 494 Async::Ready(buf) => { in read_async() [all …]
|
/dports/devel/sccache/sccache-0.2.15/cargo-crates/hyper-0.12.35/src/proto/h1/ |
H A D | decode.rs | 6 use futures::{Async, Poll}; 113 Ok(Async::Ready(buf)) in decode() 139 Ok(Async::Ready(slice)) in decode() 209 Ok(Async::Ready(ChunkedState::Size)) in read_size() 324 use futures::{Async, Poll}; 345 impl HelpUnwrap<Bytes> for Async<Bytes> { implementation 348 Async::Ready(bytes) => bytes, in unwrap() 349 Async::NotReady => panic!(), in unwrap() 357 Async::NotReady => panic!(), in unwrap() 493 Async::Ready(buf) => { in read_async() [all …]
|
/dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/hyper-0.12.35/src/proto/h1/ |
H A D | decode.rs | 6 use futures::{Async, Poll}; 113 Ok(Async::Ready(buf)) in decode() 139 Ok(Async::Ready(slice)) in decode() 209 Ok(Async::Ready(ChunkedState::Size)) in read_size() 324 use futures::{Async, Poll}; 345 impl HelpUnwrap<Bytes> for Async<Bytes> { implementation 348 Async::Ready(bytes) => bytes, in unwrap() 349 Async::NotReady => panic!(), in unwrap() 357 Async::NotReady => panic!(), in unwrap() 493 Async::Ready(buf) => { in read_async() [all …]
|
/dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/hyper-0.12.19/src/proto/h1/ |
H A D | decode.rs | 6 use futures::{Async, Poll}; 113 Ok(Async::Ready(buf)) in decode() 139 Ok(Async::Ready(slice)) in decode() 209 Ok(Async::Ready(ChunkedState::Size)) in read_size() 324 use futures::{Async, Poll}; 345 impl HelpUnwrap<Bytes> for Async<Bytes> { implementation 348 Async::Ready(bytes) => bytes, in unwrap() 349 Async::NotReady => panic!(), in unwrap() 357 Async::NotReady => panic!(), in unwrap() 493 Async::Ready(buf) => { in read_async() [all …]
|