Struct Coroutine

pub struct Coroutine<'a>(/* private fields */);

Context object that represents the currently executing coroutine.

Implementations

impl<'a> Coroutine<'a>

pub fn wrap<R, E>(&self) -> CoroutineHandler<R, E>

where R: Send + 'static, E: Send + 'static,

Provides a Coroutine handler to asynchronous operation.

The CoroutineHandler has trait the Handler, that type of Handler::Output is io::Result<R>.

Examples

use asyncio::{IoContext, AsIoContext, Stream};
use asyncio::ip::{IpProtocol, Tcp, TcpSocket};

let ctx = &IoContext::new().unwrap();
IoContext::spawn(ctx, |coro| {
  let ctx = coro.as_ctx();
  let mut soc = TcpSocket::new(ctx, Tcp::v4()).unwrap();
  let mut buf = [0; 256];
  let size = soc.async_read_some(&mut buf, coro.wrap()).unwrap();
});

Trait Implementations

impl<'a> AsIoContext for Coroutine<'a>

fn as_ctx(&self) -> &IoContext