Introduction

@hyperse/pipeline is a powerful TypeScript middleware engine and reactive pipeline library. It provides two complementary paradigms for handling data flow, and you can pick whichever fits the problem — or combine them.

Two paradigmsCopy Anchor Link

Middleware EngineCopy Anchor Link

The Pipeline class composes middleware functions that share a context object and run in sequence. Each middleware receives (context, next, error) and decides whether to continue the chain.

import { Pipeline } from '@hyperse/pipeline';

type Context = { logs: string[] };

const engine = new Pipeline<Context>(async (ctx, next) => {
  ctx.logs.push('first');
  await next();
});

engine.use(async (ctx, next) => {
  ctx.logs.push('second');
  await next();
});

const context: Context = { logs: [] };
await engine.execute(context);
// context.logs => ['first', 'second']

Reactive PipelineCopy Anchor Link

pipe composes plain functions into a single reusable, lazily evaluated function. It supports up to 10 function compositions, 0–3 parameters per function, promises, early exit and monads.

import { pipe } from '@hyperse/pipeline';

const result = await pipe(
  () => 123,
  (n) => n + 1
)();
// result => 124

Features at a glanceCopy Anchor Link

Middleware engineCopy Anchor Link

• Type-safe middleware composition with full TypeScript support
• Async/await friendly, with automatic error propagation
• Context sharing between middleware functions
• Chaining and composition via use()

Reactive pipelineCopy Anchor Link

• Functional composition with up to 10 functions
• Promise and async support throughout
• Early exit with exitPipe / isExitPipeValue
• Global context injection with pipeContext
• Dynamic modification with replace and replaceUndo
• Monad support for Either, Maybe and Validation
• Integrations with fp-ts, monet and purify-ts

Type systemCopy Anchor Link

• Generic inference for context and return types
• Function signature preservation across compositions
• Monad detection for automatic composition
• Parameter count validation (0–3 parameters per function)

Next stepsCopy Anchor Link