Struct fibers_transport::FixedPeerTransporter

pub struct FixedPeerTransporter<T: Transport, P = <T as Transport>::PeerAddr> { /* fields omitted */ }

An implementation of Transport used for communicating with a fixed peer.

Methods

impl<T: Transport, P> FixedPeerTransporter<T, P>

pub fn new(exterior_peer: P, interior_peer: T::PeerAddr, inner: T) -> Self

Makes a new FixedPeerTransporter instance.

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn inner_ref(&self) -> &T

Returns a reference to the inner transporter.

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn inner_mut(&mut self) -> &mut T

Returns a mutable reference to the inner transporter.

Important traits for &'a mut R

impl<'a, R> Read for &'a mut R where
    R: Read + ?Sized, impl<'a, W> Write for &'a mut W where
    W: Write + ?Sized, impl<'a, I> Iterator for &'a mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;

pub fn exterior_peer(&self) -> &P

Returns a reference to the fixed peer address exposed to users of the transporter.

pub fn interior_peer(&self) -> &T::PeerAddr

Returns a reference to the fixed peer address used internally in the transporter.

Trait Implementations

impl<T: Debug + Transport, P: Debug> Debug for FixedPeerTransporter<T, P> where     T::PeerAddr: Debug,

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

Formats the value using the given formatter.

impl<T: Transport, P: PeerAddr> Transport for FixedPeerTransporter<T, P>

type PeerAddr = P

Peer address.

type SendItem = T::SendItem

Outgoing item.

type RecvItem = T::RecvItem

Incoming item.

fn start_send(     &mut self,     peer: Self::PeerAddr,     item: Self::SendItem ) -> Result<()>

Starts sending the given item to the destination peer.

fn poll_send(&mut self) -> PollSend

Polls the transmission of the all outstanding items in the transporter have been completed.

fn poll_recv(&mut self) -> PollRecv<(Self::PeerAddr, Self::RecvItem)>

Polls reception of an item from a peer.

impl<T: UdpTransport> UdpTransport for FixedPeerTransporter<T, SocketAddr>

fn local_addr(&self) -> SocketAddr

Returns the address to which the instance is bound.

impl<T: TcpTransport> From<T> for FixedPeerTransporter<T, SocketAddr>

fn from(f: T) -> Self

Performs the conversion.