Struct Transport

pub struct Transport { /* private fields */ }

Available on crate feature relay only.

A Transport enabling client relay capabilities.

Note: The transport only handles listening and dialing on relayed Multiaddr, and depends on an other transport to do the actual transmission of data. They should be combined through the OrTransport.

Allows the local node to:

1. Establish relayed connections by dialing /p2p-circuit addresses.

   let actual_transport = MemoryTransport::default();
   let (relay_transport, behaviour) = relay::client::new(
       PeerId::random()
   );
   let mut transport = OrTransport::new(relay_transport, actual_transport);
   let dst_addr_via_relay = Multiaddr::empty()
       .with(Protocol::Memory(40)) // Relay address.
       .with(Protocol::P2p(relay_id.into())) // Relay peer id.
       .with(Protocol::P2pCircuit) // Signal to connect via relay and not directly.
       .with(Protocol::P2p(destination_id.into())); // Destination peer id.
   transport.dial(dst_addr_via_relay, DialOpts {
        port_use: PortUse::Reuse,
        role: Endpoint::Dialer,
   }).unwrap();

2. Listen for incoming relayed connections via specific relay.

   let actual_transport = MemoryTransport::default();
   let (relay_transport, behaviour) = relay::client::new(
      local_peer_id
   );
   let mut transport = OrTransport::new(relay_transport, actual_transport);
   let relay_addr = Multiaddr::empty()
       .with(Protocol::Memory(40)) // Relay address.
       .with(Protocol::P2p(relay_id.into())) // Relay peer id.
       .with(Protocol::P2pCircuit); // Signal to listen via remote relay node.
   transport.listen_on(ListenerId::next(), relay_addr).unwrap();

Trait Implementations

impl Transport for Transport

type Output = Connection

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

type Error = Error

An error that occurred during connection setup.

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

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

type Dial = Pin<Box<dyn Future<Output = Result<Connection, Error>> + Send>>

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

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

Listens on the given Multiaddr for inbound connections with a provided ListenerId.

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

Remove a listener.

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

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

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

where Transport: Sized,

Poll for TransportEvents.

fn boxed(self) -> Boxed<Self::Output>

where Self: Sized + Send + Unpin + 'static, Self::Dial: Send + 'static, Self::ListenerUpgrade: Send + 'static, Self::Error: Send + Sync,

Boxes the transport, including custom transport errors.

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: Error + 'static,

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.