Struct glommio::net::AcceptedUnixStream

pub struct AcceptedUnixStream { /* fields omitted */ }

An Accepted Unix 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 AcceptedUnixStream.

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

Implementations

impl AcceptedUnixStream

pub fn bind_to_executor(self) -> UnixStream

Binds this AcceptedUnixStream to the current executor

This returns a UnixStream that can then be used normally

Examples

use glommio::{
    channels::shared_channel,
    net::UnixListener,
    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 = UnixListener::bind("/tmp/named").unwrap();

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

    let ex1 = LocalExecutorBuilder::new()
        .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 AcceptedUnixStream

fn clone(&self) -> AcceptedUnixStream

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AcceptedUnixStream

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

Formats the value using the given formatter.

impl Copy for AcceptedUnixStream