Struct RecvStream 

pub struct RecvStream(/* private fields */);

Receiving part of the client stream

Implementations

impl RecvStream

pub fn id(&self) -> StreamId

Get stream id

pub fn tag(&self) -> &'static str

Get io tag

pub fn stream(&self) -> &StreamRef

pub fn disconnect_on_drop(&self)

Disconnect connection on stream drop

pub async fn recv(&self) -> Option<Message>

Attempt to pull out the next value of http/2 stream

pub fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Option<Message>>

Attempt to pull out the next value of this http/2 stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

Trait Implementations

impl Debug for RecvStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for RecvStream

fn drop(&mut self)

Executes the destructor for this type.

impl Stream for RecvStream

type Item = Message

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

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.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.