boost_pipeline_concurrent_string_processing_with_middleware.ts

1import { Pipeline, Context } from '@boost/pipeline';
2
3interface CustomContext extends Context {
4  value: string;
5}
6
7async function run() {
8  const context: CustomContext = { value: 'foobar' };
9
10  const pipeline = new Pipeline<CustomContext, string>(context, 'initial value')
11    .pipe('Upper casing', async (ctx, value) => value.toUpperCase())
12    .pipe('Appending suffix', async (ctx, value) => `${value}!`)
13    .pipe('Logging', async (ctx, value) => {
14      console.log('Final value:', value);
15      return value;
16    });
17
18  const result = await pipeline.run();
19  
20  return result;
21}
22
23run().catch(console.error);