| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_cli_serve_with_print.rs | 26 let _ = get_stderr().blocking_write_and_flush(b"start a print "); in handle()
27 let _ = get_stderr().blocking_write_and_flush(b"1"); in handle()
28 let _ = get_stderr().blocking_write_and_flush(b"2"); in handle()
29 let _ = get_stderr().blocking_write_and_flush(b"3"); in handle()
30 let _ = get_stderr().blocking_write_and_flush(b"4"); in handle()
31 let _ = get_stderr().blocking_write_and_flush(b"\n"); in handle()
|
| H A D | p2_http_outbound_request_content_length.rs | 34 .blocking_write_and_flush("long enough".as_bytes()) in main()
49 .blocking_write_and_flush("msg".as_bytes()) in main()
70 .blocking_write_and_flush("more than 11 bytes".as_bytes()) in main()
|
| H A D | p2_file_read_write.rs | 18 stream.blocking_write_and_flush(b"Hello, ").unwrap(); in main()
19 stream.blocking_write_and_flush(b"World!").unwrap(); in main()
|
| H A D | p2_api_proxy.rs | 25 let _ = out.blocking_write_and_flush(b"hello, world!"); in handle()
75 out.blocking_write_and_flush(b"hello, world!") in handle()
90 let _ = out.blocking_write_and_flush(format!("{r:?}").as_bytes()); in response_for()
|
| H A D | p2_http_outbound_request_response_build.rs | 26 .blocking_write_and_flush("request-body".as_bytes()) in main()
39 .blocking_write_and_flush("response-body".as_bytes()) in main()
|
| H A D | p2_cli_much_stdout.rs | 10 stdout.blocking_write_and_flush(chunk).unwrap(); in main()
|
| H A D | p2_cli_serve_hello_world.rs | 19 out.blocking_write_and_flush(b"Hello, WASI!") in handle()
|
| H A D | p2_cli_serve_config.rs | 21 out.blocking_write_and_flush(config.as_bytes()) in handle()
|
| H A D | p2_cli_serve_keyvalue.rs | 22 out.blocking_write_and_flush(&data) in handle()
|
| H A D | p2_api_proxy_forward_request.rs | 32 out.blocking_write_and_flush(res.body.as_ref()) in handle()
|
| H A D | p2_cli_hostcall_fuel.rs | 106 .blocking_write_and_flush(&[0; 5001]) in write_stream_blocking()
207 .blocking_write_and_flush(&[0; 5000]) in write_stream_buffer_too_large()
|
| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | impls.rs | 140 async fn blocking_write_and_flush( in blocking_write_and_flush() method
152 .blocking_write_and_flush(bytes.into()) in blocking_write_and_flush()
170 self.get_mut(&stream)?.blocking_write_and_flush(bs).await in blocking_write_zeroes_and_flush()
244 output.blocking_write_and_flush(contents).await?; in blocking_splice()
|
| H A D | streams.rs | 204 async fn blocking_write_and_flush(&mut self, mut bytes: Bytes) -> StreamResult<()> { in blocking_write_and_flush() method
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | io.rs | 41 fn blocking_write_and_flush( in blocking_write_and_flush() method
47 AsyncHostOutputStream::blocking_write_and_flush(self, stream, bytes).await in blocking_write_and_flush()
|
| /wasmtime-44.0.1/crates/wasi-preview1-component-adapter/src/ |
| H A D | macros.rs | 11 let _ = get_stderr().blocking_write_and_flush(message); in print()
|
| H A D | lib.rs | 1220 match file.fd.append_via_stream()?.blocking_write_and_flush(bytes) { in fd_pwrite()
2588 match output_stream.blocking_write_and_flush(chunk) { in write()
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | cli.rs | 345 blocking_write_and_flush(&mut *stream, "x".into()) in async_stdout_stream_unblocks()
357 async fn blocking_write_and_flush(s: &mut dyn OutputStream, mut bytes: Bytes) -> Result<()> { in blocking_write_and_flush() function
|
| H A D | p1.rs | 312 Streams::blocking_write_and_flush(host, output_stream.borrowed(), Vec::from(chunk)) in write()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | filesystem.rs | 305 async fn blocking_write_and_flush(&mut self, buf: Bytes) -> StreamResult<()> { in blocking_write_and_flush() method
|