Lines Matching refs:RecvError

2 use crate::codec::{RecvError, UserError};
71 State(RecvError),
133 ) -> Result<Option<StreamId>, RecvError> { in open() argument
141 return Err(RecvError::Connection(Reason::PROTOCOL_ERROR)); in open()
185 return Err(RecvError::Stream { in recv_headers()
321 ) -> Result<(), RecvError> { in recv_trailers() argument
327 return Err(RecvError::Stream { in recv_trailers()
464 ) -> Result<(), RecvError> { in apply_local_settings() argument
511 .map_err(RecvError::Connection)?; in apply_local_settings()
533 ) -> Result<(), RecvError> { in recv_data() argument
551 return Err(RecvError::Connection(Reason::PROTOCOL_ERROR)); in recv_data()
582 return Err(RecvError::Stream { in recv_data()
594 return Err(RecvError::Stream { in recv_data()
607 return Err(RecvError::Stream { in recv_data()
615 return Err(RecvError::Connection(Reason::PROTOCOL_ERROR)); in recv_data()
634 pub fn ignore_data(&mut self, sz: WindowSize) -> Result<(), RecvError> { in ignore_data() argument
650 pub fn consume_connection_window(&mut self, sz: WindowSize) -> Result<(), RecvError> { in consume_connection_window() argument
657 return Err(RecvError::Connection(Reason::FLOW_CONTROL_ERROR)); in consume_connection_window()
672 ) -> Result<(), RecvError> { in recv_push_promise() argument
691 return Err(RecvError::Stream { in recv_push_promise()
717 return Err(RecvError::Stream { in recv_push_promise()
792 pub fn next_stream_id(&self) -> Result<StreamId, RecvError> { in next_stream_id() argument
796 Err(RecvError::Connection(Reason::PROTOCOL_ERROR)) in next_stream_id()
811 pub fn ensure_can_reserve(&self) -> Result<(), RecvError> { in ensure_can_reserve() argument
814 return Err(RecvError::Connection(Reason::PROTOCOL_ERROR)); in ensure_can_reserve()
1099 impl<T> From<RecvError> for RecvHeaderBlockError<T> {
1100 fn from(err: RecvError) -> Self { in from()