Struct P2pRecvStream 

pub struct P2pRecvStream { /* private fields */ }

A LinkRecvStream implementation wrapping a high-level receive stream.

Implementations

impl P2pRecvStream

pub fn new(inner: HighLevelRecvStream) -> Self

Create a new receive stream wrapper.

Trait Implementations

impl LinkRecvStream for P2pRecvStream

fn read<'a>( &'a mut self, buf: &'a mut [u8], ) -> BoxFuture<'a, LinkResult<Option<usize>>>

Read data from the stream.

fn read_to_end( &mut self, size_limit: usize, ) -> BoxFuture<'_, LinkResult<Vec<u8>>>

Read all data until the stream ends.

fn stop(&mut self, error_code: u64) -> LinkResult<()>

Stop receiving data (signal we don’t want more).

fn id(&self) -> u64

Get the stream ID.