Lines Matching refs:StreamResult
153 use wit_bindgen::{FutureReader, FutureWriter, StreamReader, StreamResult, StreamWriter};
580 assert_eq!(status, StreamResult::Complete(payload.ready_count as usize)); in run()
593 assert_eq!(status, StreamResult::Dropped); in run()
603 assert_eq!(status, StreamResult::Complete(payload.ready_count as usize)); in run()
613 assert_eq!(status, StreamResult::Dropped); in run()
636 StreamResult::Complete(n) => { in run()
640 StreamResult::Dropped => { in run()
644 StreamResult::Cancelled => {} in run()
663 type Output = (StreamResult, Vec<u32>); in run()
694 StreamResult::Complete(_) => { in run()
697 StreamResult::Dropped => { in run()
701 StreamResult::Cancelled => {} in run()
720 type Output = (StreamResult, Vec<u32>); in run()