| /wasmtime-44.0.1/tests/misc_testsuite/component-model/async/ |
| H A D | streams.wast | 8 (type $stream-type (stream u8))
9 (core func $stream-new (canon stream.new $stream-type))
20 (type $stream-type (stream u8))
30 (type $stream-type (stream))
31 (core func $stream-read (canon stream.read $stream-type async))
57 (type $stream-type (stream u8))
67 (type $stream-type (stream))
77 (type $stream-type (stream u8))
87 (type $stream-type (stream u8))
97 (type $stream-type (stream u8))
[all …]
|
| H A D | sync-streams.wast | 5 ;; This test calls sync stream.write in $C.get and sync stream.read in $C.set.
22 (import "" "stream.new" (func $stream.new (result i64)))
83 (canon stream.new $ST (core func $stream.new))
92 (export "stream.new" (func $stream.new))
93 (export "stream.read" (func $stream.read))
94 (export "stream.write" (func $stream.write))
115 (import "" "stream.new" (func $stream.new (result i64)))
159 (canon stream.new $ST (core func $stream.new))
168 (export "stream.new" (func $stream.new))
169 (export "stream.read" (func $stream.read))
[all …]
|
| H A D | intra-streams.wast | 13 (type $s (stream string))
14 (core func $stream.new (canon stream.new $s))
15 …(core func $stream.read (canon stream.read $s async (memory $libc "m") (realloc (func $libc "reall…
16 (core func $stream.write (canon stream.write $s async (memory $libc "m")))
20 (import "" "stream.new" (func $stream.new (result i64)))
21 (import "" "stream.read" (func $stream.read (param i32 i32 i32) (result i32)))
22 (import "" "stream.write" (func $stream.write (param i32 i32 i32) (result i32)))
28 (local.set $tmp (call $stream.new))
46 (export "stream.new" (func $stream.new))
47 (export "stream.read" (func $stream.read))
[all …]
|
| H A D | partial-stream-copies.wast | 24 (import "" "stream.new" (func $stream.new (result i64)))
116 (canon stream.new $ST (core func $stream.new))
126 (export "stream.new" (func $stream.new))
127 (export "stream.read" (func $stream.read))
128 (export "stream.write" (func $stream.write))
129 (export "stream.drop-readable" (func $stream.drop-readable))
148 (import "" "stream.new" (func $stream.new (result i64)))
219 (canon stream.new $ST (core func $stream.new))
230 (export "stream.new" (func $stream.new))
231 (export "stream.read" (func $stream.read))
[all …]
|
| H A D | async-builtins.wast | 4 ;; stream.cancel-read
7 (import "" "stream.cancel-read" (func $stream-cancel-read (param i32) (result i32)))
9 (type $stream-type (stream u8))
10 (core func $stream-cancel-read (canon stream.cancel-read $stream-type async))
11 …(core instance $i (instantiate $m (with "" (instance (export "stream.cancel-read" (func $stream-ca…
14 ;; stream.cancel-write
17 (import "" "stream.cancel-write" (func $stream-cancel-write (param i32) (result i32)))
19 (type $stream-type (stream u8))
20 (core func $stream-cancel-write (canon stream.cancel-write $stream-type async))
21 …(core instance $i (instantiate $m (with "" (instance (export "stream.cancel-write" (func $stream-c…
|
| H A D | trap-if-done.wast | 32 (import "" "stream.new" (func $stream.new (result i64)))
108 (canon stream.new $ST (core func $stream.new))
119 (export "stream.new" (func $stream.new))
120 (export "stream.write" (func $stream.write))
127 (func (export "start-stream") (result (stream u8)) (canon lift (core func $cm "start-stream")))
138 (export "start-stream" (func (result (stream u8))))
394 (canon stream.new $ST (core func $stream.new))
413 (export "stream.new" (func $stream.new))
414 (export "stream.read" (func $stream.read))
420 (export "start-stream" (func $start-stream'))
[all …]
|
| H A D | stream-cancel-finished-op.wast | 9 (import "" "stream.new" (func $stream.new (result i64)))
187 (core func $stream.new (canon stream.new $s))
190 (core func $stream.cancel-read (canon stream.cancel-read $s))
191 (core func $stream.cancel-write (canon stream.cancel-write $s))
205 (export "stream.new" (func $stream.new))
206 (export "stream.read" (func $stream.read))
207 (export "stream.write" (func $stream.write))
208 (export "stream.cancel-read" (func $stream.cancel-read))
209 (export "stream.cancel-write" (func $stream.cancel-write))
210 (export "stream.drop-writable" (func $stream.drop-writable))
[all …]
|
| H A D | streams-massive-send.wast | 11 (type $s (stream $t))
21 (import "" "stream.new" (func $stream.new (result i64)))
142 (core func $stream.new (canon stream.new $s))
151 (export "stream.new" (func $stream.new))
152 (export "stream.write" (func $stream.write))
154 (export "task.return stream" (func $task.return-stream))
180 (import "" "big-stream" (func $big-stream (result i32)))
201 (core func $big-stream (canon lower (func $a "big-stream")))
218 (export "big-stream" (func $big-stream))
221 (export "stream.read" (func $stream.read))
[all …]
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | io.rs | 34 Ok(AsyncHostOutputStream::check_write(self, stream)?) in check_write()
38 Ok(AsyncHostOutputStream::write(self, stream, bytes)?) in write()
43 stream: Resource<OutputStream>, in blocking_write_and_flush()
53 stream: Resource<OutputStream>, in blocking_write_zeroes_and_flush()
63 stream: Resource<OutputStream>, in subscribe()
65 Ok(AsyncHostOutputStream::subscribe(self, stream)?) in subscribe()
69 Ok(AsyncHostOutputStream::write_zeroes(self, stream, len)?) in write_zeroes()
75 Resource::new_borrow(stream.rep()), in flush()
110 AsyncHostInputStream::read(self, stream, len) in read()
118 AsyncHostInputStream::skip(self, stream, len) in skip()
[all …]
|
| /wasmtime-44.0.1/crates/fuzzing/wit/ |
| H A D | fuzz.wit | 58 stream-write-ready(stream-ready-payload),
59 stream-read-ready(stream-ready-payload),
60 stream-write-pending(stream-write-payload),
61 stream-read-pending(stream-read-payload),
62 stream-write-dropped(stream-write-payload),
63 stream-read-dropped(stream-read-payload),
66 stream-write-assert-complete(stream-read-payload),
67 stream-write-assert-dropped(stream-read-payload),
68 stream-read-assert-complete(stream-write-payload),
130 stream-take: func(id: u32) -> stream<u32>;
[all …]
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_file_read_write.rs | 17 let stream = file.write_via_stream(5).unwrap(); in main() localVariable
19 stream.blocking_write_and_flush(b"World!").unwrap(); in main()
20 drop(stream); in main()
22 let stream = file.read_via_stream(0).unwrap(); in main() localVariable
23 let contents = stream.blocking_read(100).unwrap(); in main()
25 drop(stream); in main()
29 let stream = file.read_via_stream(0).unwrap(); in main() localVariable
30 let ready = stream.subscribe(); in main()
34 match stream.read(0) { in main()
40 match stream.read(4) { in main()
[all …]
|
| H A D | p2_api_proxy_streaming.rs | 87 let mut stream = in handle_request() localVariable
207 let mut stream = executor::incoming_body( in double_echo() localVariable
214 while let Some(chunk) = stream.next().await { in double_echo()
308 use futures::{Sink, Stream, future, sink, stream};
384 drop(stream); in outgoing_body()
470 stream: InputStream, in incoming_body()
483 drop(stream); in incoming_body()
491 stream::poll_fn({ in incoming_body()
492 let stream = body.stream().expect("response body should be readable"); in incoming_body() localVariable
498 Inner::Stream { stream, .. } => match stream.read(READ_SIZE) { in incoming_body()
[all …]
|
| H A D | p2_udp_connect.rs | 16 _ = client.stream(None).unwrap(); in test_udp_connect_disconnect_reconnect()
19 _ = client.stream(None).unwrap(); in test_udp_connect_disconnect_reconnect()
22 _ = client.stream(Some(remote1)).unwrap(); in test_udp_connect_disconnect_reconnect()
25 _ = client.stream(Some(remote1)).unwrap(); in test_udp_connect_disconnect_reconnect()
28 _ = client.stream(Some(remote2)).unwrap(); in test_udp_connect_disconnect_reconnect()
31 _ = client.stream(None).unwrap(); in test_udp_connect_disconnect_reconnect()
34 _ = client.stream(Some(remote1)).unwrap(); in test_udp_connect_disconnect_reconnect()
45 sock.stream(Some(addr)), in test_udp_connect_unspec()
57 sock.stream(Some(addr)), in test_udp_connect_port_0()
74 sock.stream(Some(remote_addr)), in test_udp_connect_wrong_family()
[all …]
|
| /wasmtime-44.0.1/crates/misc/component-async-tests/wit/ |
| H A D | test.wit | 70 read-stream(string),
71 read-stream-zero,
74 write-stream-zero,
79 caller-stream: stream<string>,
111 interface run-stream {
132 read-stream: async func(rx: stream<u8>, expected: list<u8>);
192 short-reads: async func(s: stream<thing>) -> stream<thing>;
277 export run-stream;
282 import run-stream;
297 import unit-stream;
[all …]
|
| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | impls.rs | 122 self.delete(stream)?.cancel().await; in drop()
137 subscribe(self, stream) in subscribe()
142 stream: Resource<DynOutputStream>, in blocking_write_and_flush()
151 self.get_mut(&stream)? in blocking_write_and_flush()
158 stream: Resource<DynOutputStream>, in blocking_write_zeroes_and_flush()
179 self.get_mut(&stream)?.flush()?; in flush()
184 let s = self.get_mut(&stream)?; in blocking_flush()
251 self.delete(stream)?.cancel().await; in drop()
264 stream: Resource<DynInputStream>, in blocking_read()
281 stream: Resource<DynInputStream>, in blocking_skip()
[all …]
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p3/wit/deps/tls/ |
| H A D | client.wit | 7 /// Set up the encryption stream transform.
8 /// This takes an unprotected `cleartext` application data stream and
9 /// returns an encrypted data stream, ready to be sent out over the network.
10 …/// Closing the `cleartext` stream will cause a `close_notify` packet to be emitted on the returne…
11 send: func(cleartext: stream<u8>) -> tuple<stream<u8>, future<result<_, error>>>;
13 /// Set up the decryption stream transform.
14 /// This takes an encrypted data stream, as received via e.g. the network,
15 /// and returns a decrypted application data stream.
16 receive: func(ciphertext: stream<u8>) -> tuple<stream<u8>, future<result<_, error>>>;
|
| /wasmtime-44.0.1/crates/debugger/wit/deps/ |
| H A D | io.wit | 81 /// stream types.
92 /// An error for input-stream and output-stream operations.
94 variant stream-error {
100 /// `stream-error::closed`.
103 /// stream. A closed output-stream will return this error on all
117 resource input-stream {
183 resource output-stream {
264 /// Write zeroes to a stream.
312 splice: func(src: borrow<input-stream>, len: u64) -> result<u64, stream-error>;
316 /// `output-stream` is ready for writing, and the `input-stream`
[all …]
|
| /wasmtime-44.0.1/crates/wasi/src/p2/wit/deps/ |
| H A D | io.wit | 81 /// stream types.
92 /// An error for input-stream and output-stream operations.
94 variant stream-error {
100 /// `stream-error::closed`.
103 /// stream. A closed output-stream will return this error on all
117 resource input-stream {
183 resource output-stream {
264 /// Write zeroes to a stream.
312 splice: func(src: borrow<input-stream>, len: u64) -> result<u64, stream-error>;
316 /// `output-stream` is ready for writing, and the `input-stream`
[all …]
|
| /wasmtime-44.0.1/crates/wasi-http/wit/deps/ |
| H A D | io.wit | 81 /// stream types.
92 /// An error for input-stream and output-stream operations.
94 variant stream-error {
100 /// `stream-error::closed`.
103 /// stream. A closed output-stream will return this error on all
117 resource input-stream {
183 resource output-stream {
264 /// Write zeroes to a stream.
312 splice: func(src: borrow<input-stream>, len: u64) -> result<u64, stream-error>;
316 /// `output-stream` is ready for writing, and the `input-stream`
[all …]
|
| /wasmtime-44.0.1/crates/wasi-tls/wit/deps/ |
| H A D | io.wit | 81 /// stream types.
92 /// An error for input-stream and output-stream operations.
94 variant stream-error {
100 /// `stream-error::closed`.
103 /// stream. A closed output-stream will return this error on all
117 resource input-stream {
183 resource output-stream {
264 /// Write zeroes to a stream.
312 splice: func(src: borrow<input-stream>, len: u64) -> result<u64, stream-error>;
316 /// `output-stream` is ready for writing, and the `input-stream`
[all …]
|
| /wasmtime-44.0.1/crates/wasi-io/wit/deps/ |
| H A D | io.wit | 81 /// stream types.
92 /// An error for input-stream and output-stream operations.
94 variant stream-error {
100 /// `stream-error::closed`.
103 /// stream. A closed output-stream will return this error on all
117 resource input-stream {
183 resource output-stream {
264 /// Write zeroes to a stream.
312 splice: func(src: borrow<input-stream>, len: u64) -> result<u64, stream-error>;
316 /// `output-stream` is ready for writing, and the `input-stream`
[all …]
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | pulley_provenance_test_async_component.wat | 116 (import "" "stream.new" (func $stream.new (result i64)))
177 (type $s (stream u8))
178 (core func $stream.new (canon stream.new $s))
179 (core func $stream.read (canon stream.read $s async (memory $libc "mem")))
181 (core func $stream.drop-readable (canon stream.drop-readable $s))
182 (core func $stream.drop-writable (canon stream.drop-writable $s))
189 (export "stream.new" (func $stream.new))
190 (export "stream.read" (func $stream.read))
191 (export "stream.write" (func $stream.write))
192 (export "stream.drop-readable" (func $stream.drop-readable))
[all …]
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | io.rs | 76 Self(FutureState::Ready(stream)) in new()
86 let stream = match &mut self.0 { in poll_read() localVariable
87 FutureState::Ready(stream) => stream, in poll_read()
92 stream in poll_read()
111 stream in poll_read()
135 Self(FutureState::Ready(stream)) in new()
281 fn new(stream: IO) -> Self { in new()
282 Self::Ready(stream) in new()
306 Ok(stream) in write()
322 Ok(stream) in flush()
[all …]
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | tcp.rs | 50 stream: Arc<tokio::net::TcpStream>, field
57 stream, in new()
102 self.stream.readable().await.unwrap(); in ready()
125 stream: Arc<tokio::net::TcpStream>, field
140 stream, in new()
146 stream.try_write(buf).map_err(|error| { in try_write_portable()
164 let stream = self.stream.clone(); in background_write() localVariable
172 stream.writable().await?; in background_write()
252 let writable = self.stream.writable(); in check_write()
270 let stream = self.stream.clone(); in shutdown() localVariable
[all …]
|
| /wasmtime-44.0.1/crates/wasi-tls/wit/deps/tls/ |
| H A D | types.wit | 4 use wasi:io/[email protected].{input-stream, output-stream};
13 constructor(server-name: string, input: input-stream, output: output-stream);
31 …get: func() -> option<result<result<tuple<client-connection, input-stream, output-stream>, io-erro…
|