Struct Scheduler

pub struct Scheduler {
    pub client_next: Client,
    pub tag_generator: TagGenerator,
    /* private fields */
}

Scheduler managing enqueued tasks and routing incoming responses to active tasks.

Fields

client_next: Client

tag_generator: TagGenerator

Implementations

impl Scheduler

pub fn new(client_next: ClientNext) -> Self

Create a new scheduler.

pub fn enqueue_task<T>(&mut self, task: T) -> TaskHandle<T>

where T: Task,

Enqueue a Task.

pub fn enqueue_input(&mut self, bytes: &[u8])

pub fn progress(&mut self) -> Result<SchedulerEvent, Interrupt<SchedulerError>>

Progress the connection returning the next event.

Trait Implementations

impl State for Scheduler

type Event = SchedulerEvent

Event emitted while progressing the state.

type Error = SchedulerError

Error emitted while progressing the state.

fn enqueue_input(&mut self, bytes: &[u8])

Enqueue input bytes.

fn next(&mut self) -> Result<Self::Event, Interrupt<Self::Error>>

Progress the state until the next event (or interrupt).