Struct ockam_transport_tcp::TcpTransport

pub struct TcpTransport { /* fields omitted */ }

High level management interface for TCP transports

Be aware that only one TcpTransport can exist per node, as it registers itself as a router for the TCP address type. Multiple calls to TcpTransport::create will fail.

To register additional connections on an already initialised TcpTransport, use tcp.connect(). To listen for incoming connections use tcp.listen()

use ockam_transport_tcp::TcpTransport;
let tcp = TcpTransport::create(&ctx).await?;
tcp.listen("127.0.0.1:8000").await?; // Listen on port 8000
tcp.connect("127.0.0.1:5000").await?; // And connect to port 5000

The same TcpTransport can also bind to multiple ports.

let tcp = TcpTransport::create(&ctx).await?;
tcp.listen("127.0.0.1:8000").await?; // Listen on port 8000
tcp.listen("127.0.0.1:9000").await?; // Listen on port 9000

Implementations

impl TcpTransport

pub async fn create(ctx: &Context) -> Result<Self>

Create a new TCP transport and router for the current node

pub async fn connect(&self, peer: impl Into<String>) -> Result<()>

Establish an outgoing TCP connection on an existing transport

pub async fn listen(&self, bind_addr: impl Into<String>) -> Result<()>

Start listening to incoming connections on an existing transport