Trait compio::driver::PollOpCode

pub trait PollOpCode {
    // Required methods
    fn pre_submit(self: Pin<&mut Self>) -> Result<Decision, Error>;
    fn on_event(
        self: Pin<&mut Self>,
        event: &Event
    ) -> Poll<Result<usize, Error>>;
}

Abstraction of operations.

Required Methods

fn pre_submit(self: Pin<&mut Self>) -> Result<Decision, Error>

Perform the operation before submit, and return Decision to indicate whether submitting the operation to polling is required.

fn on_event(self: Pin<&mut Self>, event: &Event) -> Poll<Result<usize, Error>>

Perform the operation after received corresponding event. If this operation is blocking, the return value should be Poll::Ready.

Implementors

impl OpCode for Accept

impl OpCode for CloseFile

impl OpCode for CloseSocket

impl OpCode for Connect

impl OpCode for FileStat

impl OpCode for OpenFile

impl OpCode for PathStat

impl OpCode for ShutdownSocket

impl OpCode for Sync

impl<D, F> OpCode for Asyncify<F, D>

where D: Send + 'static, F: FnOnce() -> BufResult<usize, D> + Send + Sync + 'static,

impl<T> OpCode for ReadAt<T>

where T: IoBufMut,

impl<T> OpCode for ReadVectoredAt<T>

where T: IoVectoredBufMut,

impl<T> OpCode for Recv<T>

where T: IoBufMut,

impl<T> OpCode for RecvFrom<T>

where T: IoBufMut,

impl<T> OpCode for RecvFromVectored<T>

where T: IoVectoredBufMut,

impl<T> OpCode for RecvVectored<T>

where T: IoVectoredBufMut,

impl<T> OpCode for Send<T>

where T: IoBuf,

impl<T> OpCode for SendTo<T>

where T: IoBuf,

impl<T> OpCode for SendToVectored<T>

where T: IoVectoredBuf,

impl<T> OpCode for SendVectored<T>

where T: IoVectoredBuf,

impl<T> OpCode for WriteAt<T>

where T: IoBuf,

impl<T> OpCode for WriteVectoredAt<T>

where T: IoVectoredBuf,