Struct IoContext

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

Implementations

impl IoContext

pub fn new() -> Result<IoContext>

Returns a new IoContext.

Panics

Panics if too many open files.

Examples

use asyncio::IoContext;

IoContext::new().unwrap();

pub fn dispatch<F>(&self, func: F)

where F: FnOnce(&IoContext) + Send + 'static,

Requests a process to invoke the given handler.

Examples

use asyncio::IoContext;
use std::sync::atomic::{Ordering, AtomicUsize, ATOMIC_USIZE_INIT};

static COUNT: AtomicUsize = ATOMIC_USIZE_INIT;

let ctx = IoContext::new().unwrap();
ctx.dispatch(|_| { COUNT.fetch_add(1, Ordering::SeqCst); });
ctx.dispatch(|_| { COUNT.fetch_add(1, Ordering::SeqCst); });
ctx.dispatch(|_| { COUNT.fetch_add(1, Ordering::SeqCst); });
assert_eq!(COUNT.load(Ordering::Relaxed), 0);

ctx.run();
assert_eq!(COUNT.load(Ordering::Relaxed), 3);

pub fn post<F>(&self, func: F)

where F: FnOnce(&IoContext) + Send + 'static,

Requests a process to invoke the given handler and return immediately.

Examples

use asyncio::IoContext;
use std::sync::atomic::{Ordering, AtomicUsize, ATOMIC_USIZE_INIT};

static COUNT: AtomicUsize = ATOMIC_USIZE_INIT;

let ctx = IoContext::new().unwrap();
ctx.post(|_| { COUNT.fetch_add(1, Ordering::SeqCst); });
ctx.post(|_| { COUNT.fetch_add(1, Ordering::SeqCst); });
ctx.post(|_| { COUNT.fetch_add(1, Ordering::SeqCst); });
assert_eq!(COUNT.load(Ordering::Relaxed), 0);

ctx.run();
assert_eq!(COUNT.load(Ordering::Relaxed), 3);

pub fn restart(&self) -> bool

Resets a stopped IoContext.

Examples

use asyncio::IoContext;

let ctx = IoContext::new().unwrap();
assert_eq!(ctx.stopped(), false);
ctx.stop();
assert_eq!(ctx.stopped(), true);
ctx.restart();
assert_eq!(ctx.stopped(), false);

pub fn run(&self) -> usize

Runs all given handlers.

Examples

use asyncio::IoContext;

let ctx = IoContext::new().unwrap();
ctx.run();

pub fn run_one(&self) -> usize

pub fn stop(&self)

Sets a stop request and cancel all of the waiting event in an IoContext.

Examples

use asyncio::IoContext;

let ctx = IoContext::new().unwrap();
ctx.stop();

pub fn stopped(&self) -> bool

Returns true if this has been stopped.

Examples

use asyncio::IoContext;

let ctx = IoContext::new().unwrap();
assert_eq!(ctx.stopped(), false);
ctx.stop();
assert_eq!(ctx.stopped(), true);

pub fn work(ctx: &IoContext) -> IoContextWork

impl IoContext

pub fn strand<'a, T>(ctx: &'a IoContext, data: T) -> StrandImmutable<'a, T>

impl IoContext

pub fn spawn<F>(ctx: &IoContext, func: F)

where F: FnOnce(Coroutine<'_>) + 'static,

Trait Implementations

impl AsIoContext for IoContext

fn as_ctx(&self) -> &IoContext

impl Clone for IoContext

fn clone(&self) -> IoContext

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for IoContext

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

Formats the value using the given formatter.

impl Send for IoContext