Struct packet_stream::PsIn
[−]
[src]
pub struct PsIn<R: AsyncRead, W, B>(_);
A stream of incoming requests from the peer.
Trait Implementations
impl<R: AsyncRead, W: AsyncWrite, B: AsRef<[u8]>> Stream for PsIn<R, W, B>[src]
type Item = (Box<[u8]>, Metadata, IncomingPacket<R, W, B>)
The payload of the packet that triggered this emission, the metadata of the packet, and a way of interacting with the peer.
type Error = IoError
Errors yielded by the stream.
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>
Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted. Read more