Struct AsyncIgtlServer 

pub struct AsyncIgtlServer { /* private fields */ }

Asynchronous OpenIGTLink server

Uses non-blocking I/O with Tokio for high-concurrency scenarios.

Examples

use openigtlink_rust::io::AsyncIgtlServer;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let server = AsyncIgtlServer::bind("127.0.0.1:18944").await?;
    let connection = server.accept().await?;
    Ok(())
}

Implementations

impl AsyncIgtlServer

pub async fn bind(addr: &str) -> Result<Self>

Bind to a local address and create a server asynchronously

Arguments

• addr - Local address to bind (e.g., “127.0.0.1:18944”)

Errors

• IgtlError::Io - Failed to bind

Examples

use openigtlink_rust::io::AsyncIgtlServer;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let server = AsyncIgtlServer::bind("127.0.0.1:18944").await?;
    Ok(())
}

pub async fn accept(&self) -> Result<AsyncIgtlConnection>

Accept a new client connection asynchronously

Errors

• IgtlError::Io - Failed to accept connection

Examples

use openigtlink_rust::io::AsyncIgtlServer;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let server = AsyncIgtlServer::bind("127.0.0.1:18944").await?;
    let connection = server.accept().await?;
    Ok(())
}

pub fn local_addr(&self) -> Result<SocketAddr>

Get the local address this server is bound to