boost_pipeline_concurrent_string_transformation_with_routines.ts

1import { ConcurrentPipeline, Context, Routine } from '@boost/pipeline';
2
3class UppercaseRoutine extends Routine<string, string, Context> {
4  async execute(context: Context, input: string) {
5    return input.toUpperCase();
6  }
7}
8
9class ExclaimRoutine extends Routine<string, string, Context> {
10  async execute(context: Context, input: string) {
11    return `${input}!`;
12  }
13}
14
15async function run() {
16  const context = new Context();
17  const pipeline = new ConcurrentPipeline(context, 'initial value')
18    .pipe(new UppercaseRoutine('upper', 'Uppercasing'))
19    .pipe(new ExclaimRoutine('exclaim', 'Exclaiming'));
20
21  const result = await pipeline.run();
22
23  console.log(result); // INITIAL VALUE!
24}
25
26run();