Trait TaskStream 

pub trait TaskStream {
    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 method
    fn max_concurrency_or_limit(&self, limit: usize) -> usize { ... }
}

Required 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