Struct rust_p2p_core::pipe::tcp_pipe::TcpPipeLine

source · 
pub struct TcpPipeLine { /* private fields */ }

Implementations§

source§

impl TcpPipeLine

source

pub fn route_key(&self) -> RouteKey

source

pub async fn shutdown(self) -> Result<()>

Close this pipeline

source§

impl TcpPipeLine

source

pub async fn into_raw(self) -> Result<(OwnedWriteHalf, OwnedReadHalf)>

source§

impl TcpPipeLine

source

pub async fn send_to(&self, buf: &[u8], route_key: &RouteKey) -> Result<()>

Writing buf to the target denoted by route_key via this pipeline

source

pub async fn recv_from(&mut self, buf: &mut [u8]) -> Result<(usize, RouteKey)>

Receive bytes from this pipeline, which the configured Decoder pre-processes usize in the Ok branch indicates how many bytes are received RouteKey in the Ok branch denotes the source where these bytes are received from

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> FromRef<T> for U
where T: Clone, U: From<T>,

source§

fn from_ref(val_ref: &T) -> U

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

source§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V