Lines Matching refs:StreamResult

486 pub enum StreamResult {  enum
649 ) -> Poll<Result<StreamResult>>; in poll_produce() argument
674 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
675 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
692 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
693 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
710 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
712 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
729 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
731 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
746 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
748 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
763 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
765 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
1082 ) -> Poll<Result<StreamResult>>; in poll_consume() argument
1200 ) -> Poll<Result<StreamResult>> { in new() argument
1215 StreamResult::Completed in new()
1217 StreamResult::Cancelled in new()
1271 ) -> Poll<Result<StreamResult>> { in pipe() argument
1289 StreamResult::Completed in pipe()
1291 StreamResult::Cancelled in pipe()
2148 dyn Fn() -> Pin<Box<dyn Future<Output = Result<StreamResult>> + Send + 'static>> + Send + Sync,
2220 -> Pin<Box<dyn Future<Output = Result<StreamResult>> + Send + 'a>>
2243 fn return_code(kind: TransmitKind, state: StreamResult, guest_offset: usize) -> Result<ReturnCode> { in return_code() argument
2246 StreamResult::Dropped => ReturnCode::Dropped(count), in return_code()
2247 StreamResult::Completed => ReturnCode::completed(kind, count), in return_code()
2248 StreamResult::Cancelled => ReturnCode::Cancelled(count), in return_code()
2257 future: Pin<Box<dyn Future<Output = Result<StreamResult>> + Send + 'static>>, in pipe_from_guest()
2274 StreamResult::Dropped => ReadState::Dropped, in pipe_from_guest()
2275 StreamResult::Completed | StreamResult::Cancelled => ReadState::HostReady { in pipe_from_guest()
2299 future: Pin<Box<dyn Future<Output = Result<StreamResult>> + Send + 'static>>, in pipe_to_guest()
2317 StreamResult::Dropped => WriteState::Dropped, in pipe_to_guest()
2318 StreamResult::Completed | StreamResult::Cancelled => WriteState::HostReady { in pipe_to_guest()
2619 (StreamResult::Completed, false) in new_transmit()
2637 StreamResult::Completed => { in new_transmit()
2649 StreamResult::Cancelled => { in new_transmit()
2657 StreamResult::Dropped => { in new_transmit()
2672 StreamResult::Dropped in new_transmit()
2674 StreamResult::Completed in new_transmit()
2779 StreamResult::Completed => { in set_consumer()
2800 StreamResult::Cancelled => { in set_consumer()
2808 StreamResult::Dropped => {} in set_consumer()
2878 StreamResult::Completed | StreamResult::Cancelled => {} in set_consumer()
2879 StreamResult::Dropped => break Ok(()), in set_consumer()
3028 let mut state = StreamResult::Completed; in write()
3031 while !matches!(state, StreamResult::Dropped) && position < limit { in write()
3041 while !(matches!(state, StreamResult::Dropped) || buffer.remaining().is_empty()) { in write()
3048 StreamResult::Dropped => ReadState::Dropped, in write()
3049 StreamResult::Completed | StreamResult::Cancelled => ReadState::HostToHost { in write()