Struct kio::Context

pub struct Context { /* fields omitted */ }

Implementations

impl Context

pub fn new(uring: Uring, spawner: LocalSpawner) -> Self

pub fn spawn<C, F>(&mut self, c: C) where
    C: FnOnce(Context) -> F,
    F: Future<Output = ()> + 'static, 

pub async fn accept(&mut self, socket: &mut TcpListener) -> Result<TcpStream>

Accepts a new connection on the given listener.

pub fn buffer(&mut self, size: usize) -> Box<[u8]>

Returns a buffer of at least the given size.

pub async fn connect<A>(&mut self, addr: A) -> Result<TcpStream> where
    A: ToSocketAddrs, 

pub fn listen<A>(&mut self, addr: A) -> Result<TcpListener> where
    A: ToSocketAddrs, 

Wrapper around net::TcpListener::bind.

pub async fn read(
    &mut self,
    stream: &mut TcpStream,
    buffer: &mut [u8]
) -> Result<usize>

Reads at least one byte into the buffer range and returns the size. If the stream is closed, returns zero.

pub async fn read_full(
    &mut self,
    stream: &mut TcpStream,
    buffer: &mut [u8]
) -> Result<usize>

Reads until the entire buffer range is populated or the stream is closed.

pub fn read_close(&self, stream: &mut TcpStream) -> Result<()>

pub async fn write(
    &mut self,
    stream: &mut TcpStream,
    buffer: &[u8]
) -> Result<usize>

Writes at least one byte within the buffer range to the socket. Returns the amount written.

pub async fn write_then(
    &mut self,
    stream: &mut TcpStream,
    buffer: &[u8]
) -> Result<usize>

Writes at least one byte within the buffer range to the socket before running the next task. Returns the amount written.

pub async fn write_full(
    &mut self,
    stream: &mut TcpStream,
    buffer: &[u8]
) -> Result<()>

Writes the entire buffer range to the socket.

pub fn write_close(&self, stream: &mut TcpStream) -> Result<()>

pub fn cancel(&mut self)

Cancels all active tasks.

pub fn timeout(&mut self, _expires: Duration) -> Self

Creates a new context that will be cancelled after the given duration.

Trait Implementations

impl Clone for Context

pub fn clone(&self) -> Context

Returns a copy of the value.

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

Performs copy-assignment from source.