main.rs

#[osaka]
fn foo(poll: Poll, a: Stream, b: Stream) {
  loop {
    let again = match a.read() {
      Ready => do something,
      Again => a,
    };
    match b.read() {
       Ready => do something
       Again => yield a.merge(b)
    };
  }
}