Trait integra8_scheduling::state_machine::TaskStream

pub trait TaskStream {
    type Payload;
    fn try_poll(&mut self) -> PollTaskResult<Self::Payload>;
    fn max_concurrency(&self) -> usize;
    fn complete_task(&mut self, path: TaskNodePath) -> bool;
    fn len(&self) -> usize;

    fn max_concurrency_or_limit(&self, limit: usize) -> usize { ... }
}

Associated Types

type Payload

Required methods

fn try_poll(&mut self) -> PollTaskResult<Self::Payload>

fn max_concurrency(&self) -> usize

fn complete_task(&mut self, path: TaskNodePath) -> bool

fn len(&self) -> usize

Provided methods

fn max_concurrency_or_limit(&self, limit: usize) -> usize

Implementors

impl<Payload> TaskStream for TaskNode<Payload>

type Payload = Payload

impl<Payload> TaskStream for TaskStateMachineNode<Payload>

type Payload = Payload

impl<Payload> TaskStream for ParallelTaskNode<Payload>

type Payload = Payload

impl<Payload> TaskStream for SerialTaskNode<Payload>

type Payload = Payload