Struct PipeWriter

pub struct PipeWriter<PeerID> { /* private fields */ }

Implementations

impl<PeerID> PipeWriter<PeerID>

pub fn udp_pipe_writer(&self) -> Option<&UdpPipeWriter>

Acquire a owned writer for writing to the pipe established by TCP

pub fn tcp_pipe_writer(&self) -> Option<&TcpPipeWriter>

Acquire a owned writer for writing to the pipe established by UDP

pub fn extensible_pipe_writer(&self) -> Option<&ExtensiblePipeWriter>

Acquire a owned writer for writing to the pipe established by other extended protocols

pub fn route_table(&self) -> &RouteTable<PeerID>

impl<PeerID> PipeWriter<PeerID>

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

Writing buf to the target denoted by route_key

pub async fn send_to_addr<A: Into<SocketAddr>>( &self, connect_protocol: ConnectProtocol, buf: BytesMut, addr: A, ) -> Result<()>

Writing buf to the target denoted by SocketAddr with the specified protocol

impl<PeerID: Hash + Eq> PipeWriter<PeerID>

pub async fn send_to_id(&self, buf: BytesMut, peer_id: &PeerID) -> Result<()>

Writing buf to the target named by peer_id

Trait Implementations

impl<PeerID: Clone> Clone for PipeWriter<PeerID>

fn clone(&self) -> PipeWriter<PeerID>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.