| /wasmtime-44.0.1/tests/misc_testsuite/component-model/async/ |
| H A D | futures-must-write.wast | 5 ;; a value while closing the readable end of a future (in $D) before reading
23 ;; create a new future, return the readable end to the caller
73 (import "" "future.drop-readable" (func $future.drop-readable (param i32)))
78 … (func $drop-readable-future-before-read (export "drop-readable-future-before-read") (result i32)
85 ;; ok to immediately drop the readable end
86 (call $future.drop-readable (local.get $fr))
105 (canon future.drop-readable $FT (core func $future.drop-readable))
113 (export "future.drop-readable" (func $future.drop-readable))
118 …(func (export "drop-readable-future-before-read") (result u32) (canon lift (core func $core "drop-…
124 …(func (export "drop-readable-future-before-read") (alias export $d "drop-readable-future-before-re…
[all …]
|
| H A D | stream-cancel-finished-op.wast | 15 (import "" "stream.drop-readable" (func $stream.drop-readable (param i32)))
27 (import "" "future.drop-readable" (func $future.drop-readable (param i32)))
137 (call $stream.drop-readable (local.get $reader))
167 (call $future.drop-readable (local.get $reader))
192 (core func $stream.drop-readable (canon stream.drop-readable $s))
200 (core func $future.drop-readable (canon future.drop-readable $f))
211 (export "stream.drop-readable" (func $stream.drop-readable))
223 (export "future.drop-readable" (func $future.drop-readable))
239 …-write" (u32.const 1)) "cannot write to stream after being notified that the readable end dropped")
241 …-write" (u32.const 2)) "cannot write to stream after being notified that the readable end dropped")
[all …]
|
| H A D | sync-streams.wast | 25 (import "" "stream.drop-readable" (func $stream.drop-readable (param i32)))
73 (call $stream.drop-readable (local.get $rx))
86 (canon stream.drop-readable $ST (core func $stream.drop-readable))
95 (export "stream.drop-readable" (func $stream.drop-readable))
118 (import "" "stream.drop-readable" (func $stream.drop-readable (param i32)))
139 (call $stream.drop-readable (local.get $rx))
162 (canon stream.drop-readable $ST (core func $stream.drop-readable))
171 (export "stream.drop-readable" (func $stream.drop-readable))
|
| H A D | futures.wast | 73 ;; future.drop-readable
76 (import "" "future.drop-readable" (func $future-drop-readable (param i32)))
79 (core func $future-drop-readable (canon future.drop-readable $future-type))
80 …i (instantiate $m (with "" (instance (export "future.drop-readable" (func $future-drop-readable)))…
|
| H A D | partial-stream-copies.wast | 27 (import "" "stream.drop-readable" (func $stream.drop-readable (param i32)))
44 ;; check the incoming readable stream end
63 ;; return the readable end of the outgoing stream to the caller
107 (call $stream.drop-readable (global.get $insr))
119 (canon stream.drop-readable $ST (core func $stream.drop-readable))
129 (export "stream.drop-readable" (func $stream.drop-readable))
151 (import "" "stream.drop-readable" (func $stream.drop-readable (param i32)))
170 ;; call 'transform' which will return a readable stream $outsr eagerly
209 (call $stream.drop-readable (local.get $outsr))
222 (canon stream.drop-readable $ST (core func $stream.drop-readable))
[all …]
|
| H A D | trap-if-done.wast | 152 (import "" "future.drop-readable" (func $future.drop-readable (param i32)))
154 (import "" "stream.drop-readable" (func $stream.drop-readable (param i32)))
212 ;; drop our readable end before writer can write
213 (call $future.drop-readable (local.get $fr))
294 (call $stream.drop-readable (local.get $sr))
321 ;; then drop our readable end
322 (call $stream.drop-readable (local.get $sr))
393 (canon future.drop-readable $FT (core func $future.drop-readable))
396 (canon stream.drop-readable $ST (core func $stream.drop-readable))
412 (export "future.drop-readable" (func $future.drop-readable))
[all …]
|
| H A D | streams.wast | 92 ;; stream.drop-readable
95 (import "" "stream.drop-readable" (func $stream-drop-readable (param i32)))
98 (core func $stream-drop-readable (canon stream.drop-readable $stream-type))
99 …i (instantiate $m (with "" (instance (export "stream.drop-readable" (func $stream-drop-readable)))…
|
| H A D | future-cancel-write-dropped.wast | 11 (core func $drop-read (canon future.drop-readable $f))
|
| H A D | future-cancel-write-completed.wast | 14 (core func $drop-read (canon future.drop-readable $f))
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | pulley_provenance_test_async_component.wat | 119 (import "" "stream.drop-readable" (func $stream.drop-readable (param i32)))
142 (call $stream.drop-readable (global.get $r))
166 ;; Reap the readable status on the `$r` handle now.
181 (core func $stream.drop-readable (canon stream.drop-readable $s))
192 (export "stream.drop-readable" (func $stream.drop-readable))
|
| /wasmtime-44.0.1/crates/fuzzing/wit/ |
| H A D | fuzz.wit | 30 // take a future readable end through the `future-take` import.
35 future-drop-readable(u32),
50 // take a stream readable end through the `stream-take` import.
55 stream-drop-readable(u32),
|
| /wasmtime-44.0.1/cranelift/codegen/src/isa/pulley_shared/inst/ |
| H A D | regs.rs | 45 $reg:expr => $readable:ident, $writable:ident;
51 pub fn $readable() -> Reg {
58 Writable::from_reg($readable())
|
| /wasmtime-44.0.1/cranelift/isle/ |
| H A D | TODO | 12 - Slightly nicer human-readable generated code
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/ |
| H A D | net.rs | 226 async fn readable(&self) -> Result<(), Error> {
227 let (readable, _writeable) = is_read_write(&self.0)?;
228 if readable { Ok(()) } else { Err(Error::io()) }
|
| /wasmtime-44.0.1/crates/wasi-common/src/tokio/ |
| H A D | file.rs | 177 async fn readable(&self) -> Result<(), Error> {
188 let _ = asyncfd.readable().await?;
|
| /wasmtime-44.0.1/crates/wasi/src/p3/wit/deps/ |
| H A D | cli.wit | 73 /// If the stream's readable end is dropped the future will resolve to success.
95 /// Otherwise if there is an error the readable end of the stream will be
111 /// Otherwise if there is an error the readable end of the stream will be
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/wit/deps/ |
| H A D | cli.wit | 73 /// If the stream's readable end is dropped the future will resolve to success.
95 /// Otherwise if there is an error the readable end of the stream will be
111 /// Otherwise if there is an error the readable end of the stream will be
|
| /wasmtime-44.0.1/crates/wasi-common/src/tokio/sched/ |
| H A D | unix.rs | 60 .readable() in poll_oneoff()
|
| /wasmtime-44.0.1/crates/wasi-common/src/ |
| H A D | file.rs | 130 async fn readable(&self) -> Result<(), Error> { in readable() method
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | tcp.rs | 102 self.stream.readable().await.unwrap(); in ready()
|
| /wasmtime-44.0.1/tests/misc_testsuite/component-model/ |
| H A D | fixed_length_lists.wast | 9 ;; are not expected to be easily human readable.
|
| /wasmtime-44.0.1/crates/environ/ |
| H A D | LICENSE | 109 include a readable copy of the attribution notices contained
|
| /wasmtime-44.0.1/crates/cache/ |
| H A D | LICENSE | 109 include a readable copy of the attribution notices contained
|
| /wasmtime-44.0.1/cranelift/module/ |
| H A D | LICENSE | 109 include a readable copy of the attribution notices contained
|
| /wasmtime-44.0.1/winch/codegen/ |
| H A D | LICENSE | 109 include a readable copy of the attribution notices contained
|