Struct Router 

pub struct Router(/* private fields */);

Handles packet forwarding between transport protocols.

Implementations

impl Router

pub fn get_receiver( &self, interface: SocketAddr, ) -> UnboundedReceiver<(Vec<u8>, ResponseMethod, SocketAddr)>

Get the socket reader for the route.

Each transport protocol is layered according to its own socket, and the data forwarded to this socket can be obtained by routing.

Example

use std::net::SocketAddr;
use turn_server::router::*;
use turn_server::turn::ResponseMethod;

#[tokio::main]
async fn main() {
    let addr = "127.0.0.1:8080".parse::<SocketAddr>().unwrap();
    let router = Router::default();
    let mut receiver = router.get_receiver(addr);

    router.send(&addr, ResponseMethod::ChannelData, &addr, &[1, 2, 3]);
    let ret = receiver.recv().await.unwrap();
    assert_eq!(ret.0, vec![1, 2, 3]);
    assert_eq!(ret.1, ResponseMethod::ChannelData);
    assert_eq!(ret.2, addr);
}

pub fn send( &self, interface: &SocketAddr, method: ResponseMethod, addr: &SocketAddr, data: &[u8], )

Send data to router.

By specifying the socket identifier and destination address, the route is forwarded to the corresponding socket. However, it should be noted that calling this function will not notify whether the socket exists. If it does not exist, the data will be discarded by default.

Example

use std::net::SocketAddr;
use turn_server::router::*;
use turn_server::turn::ResponseMethod;

#[tokio::main]
async fn main() {
    let addr = "127.0.0.1:8080".parse::<SocketAddr>().unwrap();
    let router = Router::default();
    let mut receiver = router.get_receiver(addr);

    router.send(&addr, ResponseMethod::ChannelData, &addr, &[1, 2, 3]);
    let ret = receiver.recv().await.unwrap();
    assert_eq!(ret.0, vec![1, 2, 3]);
    assert_eq!(ret.1, ResponseMethod::ChannelData);
    assert_eq!(ret.2, addr);
}

pub fn remove(&self, interface: &SocketAddr)

delete socket.

Example

use std::net::SocketAddr;
use turn_server::router::*;
use turn_server::turn::ResponseMethod;

#[tokio::main]
async fn main() {
    let addr = "127.0.0.1:8080".parse::<SocketAddr>().unwrap();
    let router = Router::default();
    let mut receiver = router.get_receiver(addr);

    router.send(&addr, ResponseMethod::ChannelData, &addr, &[1, 2, 3]);
    let ret = receiver.recv().await.unwrap();
    assert_eq!(ret.0, vec![1, 2, 3]);
    assert_eq!(ret.1, ResponseMethod::ChannelData);
    assert_eq!(ret.2, addr);

    router.remove(&addr);
    assert!(receiver.recv().await.is_none());
}

Trait Implementations

impl Clone for Router

fn clone(&self) -> Router

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Router

fn default() -> Self

Returns the “default value” for a type.