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()
319 ) -> Result<(), RecvError> { in recv_trailers() argument
325 return Err(RecvError::Stream { in recv_trailers()
462 ) -> Result<(), RecvError> { in apply_local_settings() argument
509 .map_err(RecvError::Connection)?; in apply_local_settings()
531 ) -> Result<(), RecvError> { in recv_data() argument
549 return Err(RecvError::Connection(Reason::PROTOCOL_ERROR)); in recv_data()
580 return Err(RecvError::Stream { in recv_data()
592 return Err(RecvError::Stream { in recv_data()
605 return Err(RecvError::Stream { in recv_data()
613 return Err(RecvError::Connection(Reason::PROTOCOL_ERROR)); in recv_data()
632 pub fn ignore_data(&mut self, sz: WindowSize) -> Result<(), RecvError> { in ignore_data() argument
648 pub fn consume_connection_window(&mut self, sz: WindowSize) -> Result<(), RecvError> { in consume_connection_window() argument
655 return Err(RecvError::Connection(Reason::FLOW_CONTROL_ERROR)); in consume_connection_window()
670 ) -> Result<(), RecvError> { in recv_push_promise() argument
689 return Err(RecvError::Stream { in recv_push_promise()
715 return Err(RecvError::Stream { in recv_push_promise()
790 pub fn next_stream_id(&self) -> Result<StreamId, RecvError> { in next_stream_id() argument
794 Err(RecvError::Connection(Reason::PROTOCOL_ERROR)) in next_stream_id()
809 pub fn ensure_can_reserve(&self) -> Result<(), RecvError> { in ensure_can_reserve() argument
812 return Err(RecvError::Connection(Reason::PROTOCOL_ERROR)); in ensure_can_reserve()
1097 impl<T> From<RecvError> for RecvHeaderBlockError<T> {
1098 fn from(err: RecvError) -> Self { in from()