Lines Matching refs:StreamError
81 fn read(&mut self, size: usize) -> Result<bytes::Bytes, p2::StreamError> { in read() argument
84 Err(_) => Err(p2::StreamError::trap("concurrent reads are not supported")), in read()
87 fn skip(&mut self, size: usize) -> Result<usize, p2::StreamError> { in skip() argument
90 Err(_) => Err(p2::StreamError::trap("concurrent skips are not supported")), in skip()
179 fn check_write(&mut self) -> Result<usize, p2::StreamError> { in check_write() argument
182 Err(_) => Err(p2::StreamError::trap("concurrent writes are not supported")), in check_write()
185 fn write(&mut self, bytes: Bytes) -> Result<(), p2::StreamError> { in write() argument
188 Err(_) => Err(p2::StreamError::trap("concurrent writes not supported yet")), in write()
191 fn flush(&mut self) -> Result<(), p2::StreamError> { in flush() argument
194 Err(_) => Err(p2::StreamError::trap( in flush()
310 Err(p2::StreamError::Closed) => Poll::Ready(None), in poll()
316 Err(p2::StreamError::LastOperationFailed(e)) => { in poll()
321 Err(p2::StreamError::Trap(_)) => unreachable!(), in poll()