wit-bindgen-cli 0.57.1

CLI tool to generate bindings for WIT documents and the component model. 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

//@ wasmtime-flags = '-Wcomponent-model-async'

include!(env!("BINDINGS"));

use crate::my::test::i::*;
use futures::task::noop_waker_ref;
use std::future::Future;
use std::task::Context;
use wit_bindgen::yield_async;

struct Component;

export!(Component);

impl Guest for Component {
    async fn run() {
        // Test that Rust-level polling twice works.
        {
            let (tx, rx) = wit_future::new(|| unreachable!());
            let mut import = Box::pin(pending_import(rx));
            assert!(import
                .as_mut()
                .poll(&mut Context::from_waker(noop_waker_ref()))
                .is_pending());
            assert!(import
                .as_mut()
                .poll(&mut Context::from_waker(noop_waker_ref()))
                .is_pending());
            tx.write(()).await.unwrap();
            import.await;
        }

        // Start the imported function call, get it pending, then let it complete by
        // finishing `tx`, then yield a few times to ensure that the runtime gets
        // the completion of the task-at-hand, and then drop it without completing
        // it.
        {
            let (tx, rx) = wit_future::new(|| unreachable!());
            let mut import = Box::pin(pending_import(rx));
            assert!(import
                .as_mut()
                .poll(&mut Context::from_waker(noop_waker_ref()))
                .is_pending());
            tx.write(()).await.unwrap();

            for _ in 0..5 {
                yield_async().await;
            }
            drop(import);
        }
    }
}