Lines Matching refs:reader
336 let (writer, reader) = wit_future::new(|| unreachable!()); in run()
340 let prev = s.future_readers.insert(id, reader); in run()
345 let reader = i::future_take(id); in run() localVariable
347 let prev = s.future_readers.insert(id, reader); in run()
352 let reader = State::with(|s| s.future_readers.remove(&id).unwrap()); in run() localVariable
353 i::future_receive(id, reader); in run()
363 let reader = State::with(|s| s.future_readers.remove(&payload.future).unwrap()); in run() localVariable
364 assert_eq!(assert_ready(pin!(reader.into_future())), payload.item); in run()
433 let reader = State::with(|s| s.future_readers.remove(&id).unwrap()); in run() localVariable
437 read: reader.into_future(), in run()
447 Err(reader) => { in run()
448 let prev = s.future_readers.insert(id, reader); in run()
549 let (writer, reader) = wit_stream::new(); in run()
553 let prev = s.stream_readers.insert(id, reader); in run()
558 let reader = i::stream_take(id); in run() localVariable
560 let prev = s.stream_readers.insert(id, reader); in run()
565 let reader = State::with(|s| s.stream_readers.remove(&id).unwrap()); in run() localVariable
566 i::stream_receive(id, reader); in run()
599 let reader = s.stream_readers.get_mut(&payload.stream).unwrap(); in run() localVariable
601 reader.read(Vec::with_capacity(payload.op_count as usize)) in run()
609 let reader = s.stream_readers.get_mut(&payload.stream).unwrap(); in run() localVariable
611 reader.read(Vec::with_capacity(payload.count as usize)) in run()
679 let mut reader = State::with(|s| s.stream_readers.remove(&payload.stream).unwrap()); in run() localVariable
688 read: reader.read(Vec::with_capacity(payload.count as usize)), in run()
703 let prev = s.stream_readers.insert(payload.stream, reader); in run()