Struct glommio::net::AcceptedTcpStream

pub struct AcceptedTcpStream { /* private fields */ }

An Accepted Tcp connection that can be moved to a different executor

This is useful in situations where the load balancing provided by the Operating System through ReusePort is not desirable. The user can accept the connection in one executor through shared_accept which returns an AcceptedTcpStream.

Once the AcceptedTcpStream arrives at its destination it can then be made active with bind_to_executor

Implementations

impl AcceptedTcpStream

pub fn peer_addr(&self) -> Result<SocketAddr, ()>

Returns the socket address of the remote peer

pub fn bind_to_executor(self) -> TcpStream

Binds this AcceptedTcpStream to the current executor

This returns a TcpStream that can then be used normally

Examples

use glommio::{
    channels::shared_channel,
    net::TcpListener,
    LocalExecutor,
    LocalExecutorBuilder,
};

let ex = LocalExecutor::default();
ex.run(async move {
    let (sender, receiver) = shared_channel::new_bounded(1);
    let sender = sender.connect().await;

    let listener = TcpListener::bind("127.0.0.1:0").unwrap();

    let accepted = listener.shared_accept().await.unwrap();
    sender.try_send(accepted).unwrap();

    let ex1 = LocalExecutorBuilder::default()
        .spawn(move || async move {
            let receiver = receiver.connect().await;
            let accepted = receiver.recv().await.unwrap();
            let _ = accepted.bind_to_executor();
        })
        .unwrap();

    ex1.join().unwrap();
});

Trait Implementations

impl Clone for AcceptedTcpStream

fn clone(&self) -> AcceptedTcpStream

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AcceptedTcpStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Copy for AcceptedTcpStream