Struct Completer 

pub struct Completer { /* private fields */ }

A worker’s completion queue, for other threads to hand results back to a connection that returned Step::Park.

Examples

use net_io::{Input, Session, SessionContext, Step};

struct Slow;
impl Session for Slow {
    fn on_data(&mut self, cx: &mut SessionContext<'_>, input: &mut Input) -> Step {
        let n = input.bytes().len();
        input.consume(n);
        let (completer, id) = (cx.completer(), cx.info().id);
        std::thread::spawn(move || {
            let _ = completer.post(id, 1, 42);
        });
        Step::Park { until: None }
    }
    fn on_wake(&mut self, cx: &mut SessionContext<'_>, _token: u32, value: u64) -> Step {
        let _ = cx.output().push(format!("{value}\n").as_bytes());
        Step::Write
    }
}

Implementations

impl Completer

pub fn post( &self, connection: ConnectionId, token: u32, value: u64, ) -> Result<(), PostError>

Posts a completion for connection. Never blocks.

Errors

PostError::Full, PostError::WrongWorker, PostError::ServerStopped.

pub fn worker(&self) -> WorkerId

The worker this queue belongs to.

pub fn capacity(&self) -> usize

The ring’s capacity.

Trait Implementations

impl Clone for Completer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Completer

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

Formats the value using the given formatter.