apalis_workflow/chain/
mod.rs

1// pub struct Chain<SubFlow> {
2//     sub_flow: SubFlow,
3// }
4
5// impl<L, Input, Output> Step<Input> for Chain<Workflow<Input, Output, L>> {
6//     type Response = Output;
7//     type Error = Infallible;
8//     fn register(&self, ctx: &mut Context<(), ()>) {
9//         // TODO
10//     }
11// }
12
13// impl<Input> Step<Input> for Chain<DagExecutor> {
14//     type Response = ();
15//     type Error = Infallible;
16//     fn register(&self, ctx: &mut StepRouter<()>) {
17//         // TODO
18//     }
19// }