Home
last modified time | relevance | path

Searched refs:Async (Results 151 – 175 of 10318) sorted by relevance

12345678910>>...413

/dports/www/p5-Net-Async-HTTP/Net-Async-HTTP-0.48/t/
H A D81cross-https.t7 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 DAsyncTest.cpp41 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 DConnection.pm1 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 Dpoll_evented.rs14 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 Dpoll_evented.rs14 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 Dpoll_evented.rs14 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 Dchannel.rs4 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 Dpoll_evented.rs13 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 Dchannel.rs4 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 Dchannel.rs4 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 D25socket.t6 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 D33process.t6 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 D61protocol-stream.t6 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 Dasync.rs10 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 Dasync.rs10 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 Dasync.rs10 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 Dasync.rs10 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 Dasync.rs10 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 Dasync.rs10 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 Dsync_mpsc.rs6 use futures::{Async, Poll, AsyncSink};
46 assert_eq!(Ok(Async::NotReady), rx.poll_stream_notify(&notify_noop(), 1)); in unbounded_1_tx()
51 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll_stream_notify(&notify_noop(), 1)); in unbounded_1_tx()
69 assert_eq!(Ok(Async::NotReady), rx.poll_stream_notify(&notify_noop(), 1)); in unbounded_100_tx()
73 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll_stream_notify(&notify_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(&notify_noop(), 1)); in bounded_1_tx()
[all …]
/dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/futures-0.1.23/benches/
H A Dsync_mpsc.rs6 use futures::{Async, Poll, AsyncSink};
46 assert_eq!(Ok(Async::NotReady), rx.poll_stream_notify(&notify_noop(), 1)); in unbounded_1_tx()
51 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll_stream_notify(&notify_noop(), 1)); in unbounded_1_tx()
69 assert_eq!(Ok(Async::NotReady), rx.poll_stream_notify(&notify_noop(), 1)); in unbounded_100_tx()
73 assert_eq!(Ok(Async::Ready(Some(i))), rx.poll_stream_notify(&notify_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(&notify_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 Ddecode.rs6 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 Ddecode.rs6 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 Ddecode.rs6 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 Ddecode.rs6 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 …]

12345678910>>...413