wit-bindgen-moonbit 0.58.0

MoonBit bindings generator for WIT and the component model, typically used through the `wit-bindgen-cli` crate.
Documentation 
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

///|
pub(all) struct FutureR[X](async () -> X)

///|
pub(all) struct StreamR[X] {
  read : async (Int) -> ArrayView[X]?
  close : async () -> Unit
}

///|
pub(all) struct StreamW[X] {
  write : async (ArrayView[X]) -> Int
  close : async () -> Unit
}

///|
struct OutStream[X] {
  mut stream : StreamW[X]?
  mut coroutine : Coroutine?
} derive(Default)

///|
pub async fn[X] OutStream::get_stream(self : OutStream[X]) -> StreamW[X] {
  if self.stream is Some(s) {
    return s
  } else {
    guard self.coroutine is None
    self.coroutine = Some(current_coroutine())
    suspend() catch {
      e => {
        if self.stream is Some(s) {
          (s.close)()
        }
        raise e
      }
    }
    self.stream.unwrap()
  }
}

///|
pub fn[X] OutStream::put_stream(
  self : OutStream[X],
  stream : StreamW[X],
) -> Unit {
  self.stream = Some(stream)
  if self.coroutine is Some(coro) {
    coro.wake()
  }
}