Struct TaskChainBuilder 

pub struct TaskChainBuilder { /* private fields */ }

Task chain builder

Provides a fluent interface for building task chains.

Examples

use reinhardt_tasks::{TaskChainBuilder, TaskId};

let chain = TaskChainBuilder::new("payment-flow")
    .add_task(TaskId::new())
    .add_task(TaskId::new())
    .build();

assert_eq!(chain.task_count(), 2);

Implementations

impl TaskChainBuilder

pub fn new(name: impl Into<String>) -> Self

Create a new task chain builder

Examples

use reinhardt_tasks::TaskChainBuilder;

let builder = TaskChainBuilder::new("my-workflow");

pub fn add_task(self, task_id: TaskId) -> Self

Add a task to the chain

Examples

use reinhardt_tasks::{TaskChainBuilder, TaskId};

let builder = TaskChainBuilder::new("workflow")
    .add_task(TaskId::new());

pub fn add_tasks(self, task_ids: Vec<TaskId>) -> Self

Add multiple tasks to the chain

Examples

use reinhardt_tasks::{TaskChainBuilder, TaskId};

let tasks = vec![TaskId::new(), TaskId::new(), TaskId::new()];
let chain = TaskChainBuilder::new("batch")
    .add_tasks(tasks)
    .build();

assert_eq!(chain.task_count(), 3);

pub fn build(self) -> TaskChain

Build the task chain

Examples

use reinhardt_tasks::{TaskChainBuilder, TaskId};

let chain = TaskChainBuilder::new("workflow")
    .add_task(TaskId::new())
    .build();