| /dports/audio/lewton/lewton-0.10.2/cargo-crates/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/editors/xi-term/xi-term-d264767/cargo-crates/futures-0.1.27/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/futures-0.1.31/tests/ |
| H A D | sink.rs | 46 fn send_all() { in send_all() function
49 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
52 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
56 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
363 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/futures-0.1.31/tests/ |
| H A D | sink.rs | 46 fn send_all() { in send_all() function
49 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
52 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
56 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
363 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/www/ffsend/ffsend-ccd489ce2e75b91c0f17fbf13dbd91fe84f5ad98/cargo-crates/futures-0.1.31/tests/ |
| H A D | sink.rs | 46 fn send_all() { in send_all() function
49 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
52 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
56 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
363 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/www/websocat/websocat-1.9.0/cargo-crates/futures-0.1.31/tests/ |
| H A D | sink.rs | 46 fn send_all() { in send_all() function
49 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
52 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
56 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
363 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/futures-0.1.31/tests/ |
| H A D | sink.rs | 46 fn send_all() { in send_all() function
49 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
52 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
56 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
363 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/futures-0.1.31/tests/ |
| H A D | sink.rs | 46 fn send_all() { in send_all() function
49 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
52 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
56 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
363 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/futures-0.1.29/tests/ |
| H A D | sink.rs | 44 fn send_all() { in send_all() function
47 let (v, _) = v.send_all(stream::iter_ok(vec![0, 1])).wait().unwrap(); in send_all()
50 let (v, _) = v.send_all(stream::iter_ok(vec![2, 3])).wait().unwrap(); in send_all()
54 move || v.send_all(stream::iter_ok(vec![4, 5])).map(|(v, _)| v), in send_all()
361 let (sink, _) = sink.send_all(stream).wait().unwrap(); in fanout_smoke()
|
| /dports/security/p5-Crypt-Dining/Crypt-Dining-1.01/lib/Crypt/ |
| H A D | Dining.pm | 108 sub send_all { subroutine
176 $self->send_all("hand" . $store);
|
| /dports/net/proby/proby-1.0.2/cargo-crates/futures-preview-0.3.0-alpha.19/tests/ |
| H A D | sink.rs | 86 fn send_all() { in send_all() function
89 block_on(v.send_all(&mut stream::iter(vec![0, 1]))).unwrap(); in send_all()
92 block_on(v.send_all(&mut stream::iter(vec![2, 3]))).unwrap(); in send_all()
95 block_on(v.send_all(&mut stream::iter(vec![4, 5]))).unwrap(); in send_all()
412 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]))).unwrap(); in fanout_smoke()
|
| /dports/multimedia/musikcube/musikcube-0.96.7/src/3rdparty/win32_src/microhttpd/ |
| H A D | test_upgrade.c | 557 send_all (wr_socket sock, in send_all() function
671 send_all (usock, in run_usock()
675 send_all (usock, in run_usock()
694 send_all (*sock, in run_usock_client()
699 send_all (*sock, in run_usock_client()
|
| /dports/sysutils/vector/vector-0.10.0/src/sinks/ |
| H A D | socket.rs | 150 let pump = sink.send_all(events); in tcp_stream()
256 let pump = sink.send_all(events); in tcp_stream_detects_disconnect()
278 let pump = sink.send_all(events); in tcp_stream_detects_disconnect()
|
| /dports/net/py-trio/trio-0.19.0/trio/tests/ |
| H A D | test_highlevel_open_tcp_listeners.py | 34 await s1.send_all(b"x")
35 await s2.send_all(b"x")
206 await stream.send_all(b"x")
|
| H A D | test_highlevel_serve_listeners.py | 50 await stream.send_all(b"123")
58 await s.send_all(b"456")
|
| /dports/www/p5-WWW-Myspace/WWW-Myspace-0.92/samples/ |
| H A D | send_all | 18 $message->send_all;
|
| /dports/games/minetest/minetest-5.4.1/games/devtest/mods/modchannels/ |
| H A D | init.lua | 11 mod_channel:send_all("experimental answers to preview")
|