Struct packet_stream::PsStream
[−]
[src]
pub struct PsStream<R: AsyncRead> { /* fields omitted */ }
The stream half of a duplex multiplexed over the packet-stream.
Trait Implementations
impl<R: AsyncRead> Stream for PsStream<R>[src]
Note that the stream never emits Ok(None).
type Item = (Box<[u8]>, Metadata)
Values yielded by the stream.
type Error = ConnectionError
If the peer closes the packet-stream, this emits a
ConnectionError::Closed. If an error happens/happened on the underlying
AsyncRead, this emits a ConnectionError::Errored.
fn poll_next(
&mut self,
cx: &mut Context
) -> Poll<Option<Self::Item>, Self::Error>[src]
&mut self,
cx: &mut Context
) -> Poll<Option<Self::Item>, Self::Error>
Note that the stream never emits Ok(None).