Struct disarray_network::GenTcpTransport

pub struct GenTcpTransport<T>where
    T: Provider + Send,{ /* private fields */ }

Implementations

impl<T> GenTcpTransport<T>where
    T: Provider + Send,

pub fn new(config: GenTcpConfig) -> GenTcpTransport<T>

Trait Implementations

impl<T> Default for GenTcpTransport<T>where
    T: Provider + Send,

fn default() -> GenTcpTransport<T>

Returns the “default value” for a type.

impl<T> Transport for GenTcpTransport<T>where
    T: 'static + Provider + Send,
    <T as Provider>::Listener: Unpin,
    <T as Provider>::Stream: Unpin,

fn address_translation(
    &self,
    listen: &Multiaddr,
    observed: &Multiaddr
) -> Option<Multiaddr>

When port reuse is disabled and hence ephemeral local ports are used for outgoing connections, the returned address is the observed address with the port replaced by the port of the listen address.

If port reuse is enabled, Some(observed) is returned, as there is a chance that the observed address and port are reachable for other peers if there is a NAT in the way that does endpoint- independent filtering. Furthermore, even if that is not the case and TCP hole punching techniques must be used for NAT traversal, the observed address is still the one that a remote should connect to for the purpose of the hole punching procedure, as it represents the mapped IP and port of the NAT device in front of the local node.

None is returned if one of the given addresses is not a TCP/IP address.

fn poll(
    self: Pin<&mut GenTcpTransport<T>>,
    cx: &mut Context<'_>
) -> Poll<TransportEvent<<GenTcpTransport<T> as Transport>::ListenerUpgrade, <GenTcpTransport<T> as Transport>::Error>>

Poll all listeners.

type Output = <T as Provider>::Stream

The result of a connection setup process, including protocol upgrades.

type Error = Error

An error that occurred during connection setup.

type Dial = Pin<Box<dyn Future<Output = Result<<GenTcpTransport<T> as Transport>::Output, <GenTcpTransport<T> as Transport>::Error>> + Send + 'static, Global>>

A pending Output for an outbound connection, obtained from dialing.

type ListenerUpgrade = Ready<Result<<GenTcpTransport<T> as Transport>::Output, <GenTcpTransport<T> as Transport>::Error>>

A pending Output for an inbound connection, obtained from the [Transport] stream.

fn listen_on(
    &mut self,
    addr: Multiaddr
) -> Result<ListenerId, TransportError<<GenTcpTransport<T> as Transport>::Error>>

Listens on the given [Multiaddr] for inbound connections.

fn remove_listener(&mut self, id: ListenerId) -> bool

Remove a listener.

fn dial(
    &mut self,
    addr: Multiaddr
) -> Result<<GenTcpTransport<T> as Transport>::Dial, TransportError<<GenTcpTransport<T> as Transport>::Error>>

Dials the given [Multiaddr], returning a future for a pending outbound connection.

fn dial_as_listener(
    &mut self,
    addr: Multiaddr
) -> Result<<GenTcpTransport<T> as Transport>::Dial, TransportError<<GenTcpTransport<T> as Transport>::Error>>

As [Transport::dial] but has the local node act as a listener on the outgoing connection.

fn map<F, O>(self, f: F) -> Map<Self, F>where
    Self: Sized,
    F: FnOnce(Self::Output, ConnectedPoint) -> O,

Applies a function on the connections created by the transport.

fn map_err<F, E>(self, f: F) -> MapErr<Self, F>where
    Self: Sized,
    F: FnOnce(Self::Error) -> E,

Applies a function on the errors generated by the futures of the transport.

fn or_transport<U>(self, other: U) -> OrTransport<Self, U>where
    Self: Sized,
    U: Transport,
    <U as Transport>::Error: 'static,

Adds a fallback transport that is used when encountering errors while establishing inbound or outbound connections.

fn and_then<C, F, O>(self, f: C) -> AndThen<Self, C>where
    Self: Sized,
    C: FnOnce(Self::Output, ConnectedPoint) -> F,
    F: TryFuture<Ok = O>,
    <F as TryFuture>::Error: 'static + Error,

Applies a function producing an asynchronous result to every connection created by this transport.

fn upgrade(self, version: Version) -> Builder<Self>where
    Self: Sized,
    Self::Error: 'static,

Begins a series of protocol upgrades via an upgrade::Builder.