Trait TaskFlowSink 

pub trait TaskFlowSink<Args, Compact>: Backend
where
    Self::Codec: Codec<Args>,
{
    // Required method
    fn push_step(
        &mut self,
        step: Args,
        index: usize,
    ) -> impl Future<Output = Result<(), WorkflowError>> + Send;

    // Provided method
    fn push_start(
        &mut self,
        step: Args,
    ) -> impl Future<Output = Result<(), WorkflowError>> + Send { ... }
}

Required Methods

fn push_step( &mut self, step: Args, index: usize, ) -> impl Future<Output = Result<(), WorkflowError>> + Send

Provided Methods

fn push_start( &mut self, step: Args, ) -> impl Future<Output = Result<(), WorkflowError>> + Send

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<S, Args: Send, Compact> TaskFlowSink<Args, Compact> for S

where S: WeakTaskSink<Args> + Send, S::IdType: GenerateId + Send, S::Codec: Codec<Args, Compact = Compact>, S::Context: MetadataExt<WorkflowRequest> + Send, S::Error: Error + Send + Sync + 'static, <S::Codec as Codec<Args>>::Error: Into<BoxDynError> + Send + Sync + 'static, <S::Context as MetadataExt<WorkflowRequest>>::Error: Into<BoxDynError> + Send + Sync + 'static,