| /dports/dns/encrypted-dns-server/encrypted-dns-server-0.9.1/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/dns/doh-proxy/doh-proxy-0.9.2/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/net/routinator/routinator-0.10.2/cargo-crates/futures-0.3.15/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/editors/kak-lsp/kak-lsp-11.1.0/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/databases/couchdb3/apache-couchdb-3.2.1/src/couch_index/src/ |
| H A D | couch_index.erl | 127 send_all(State#st.waiters, Reason),
211 send_all(Waiters, Reason),
274 send_all(State#st.waiters, Error),
372 catch send_all(State#st.waiters, shutdown),
384 send_all(Waiters, Reply) -> function
|
| /dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/futures-0.3.19/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/futures/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/futures/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/net/krill/krill-0.9.4/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/futures-0.3.18/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/net/oha/oha-0.4.7/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/textproc/mdbook/mdBook-0.4.13/cargo-crates/futures-0.3.16/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/textproc/mdbook-linkcheck/mdbook-linkcheck-0.7.6/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/www/miniserve/miniserve-0.18.0/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/futures/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/sysutils/czkawka/czkawka-3.3.1/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/futures-0.3.18/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/x11/sirula/sirula-1.0.0/cargo-crates/futures-0.3.17/tests/ |
| H A D | sink.rs | 253 fn send_all() { in send_all() function
256 block_on(v.send_all(&mut stream::iter(vec![0, 1]).map(Ok))).unwrap(); in send_all()
259 block_on(v.send_all(&mut stream::iter(vec![2, 3]).map(Ok))).unwrap(); in send_all()
262 block_on(v.send_all(&mut stream::iter(vec![4, 5]).map(Ok))).unwrap(); in send_all()
449 block_on(sink.send_all(&mut stream::iter(vec![1, 2, 3]).map(Ok))).unwrap(); in fanout_smoke()
|
| /dports/devel/py-celery/celery-4.4.7/celery/ |
| H A D | bootsteps.py | 134 self.send_all(parent, 'close', 'closing', reverse=False)
138 self.send_all(parent, method, description, propagate=propagate)
140 def send_all(self, parent, method, member in Blueprint
|
| /dports/security/py-ailment/binaries-9.0.5405/tests_src/ |
| H A D | atoi_leak.c | 26 int send_all(int fd, const void *msg, size_t n_bytes) in send_all() function
|
| /dports/security/py-pyvex/binaries-9.0.5405/tests_src/ |
| H A D | atoi_leak.c | 26 int send_all(int fd, const void *msg, size_t n_bytes) in send_all() function
|
| H A D | hex_leak.c | 26 int send_all(int fd, const void *msg, size_t n_bytes) in send_all() function
|
| /dports/devel/py-cle/binaries-9.0.5405/tests_src/ |
| H A D | atoi_leak.c | 26 int send_all(int fd, const void *msg, size_t n_bytes) in send_all() function
|
| H A D | hex_leak.c | 26 int send_all(int fd, const void *msg, size_t n_bytes) in send_all() function
|