pipeline.ts

An asynchronous request/response pipeline for TypeScript.

Usage

import { Pipeline } from "pipeline.ts"
 
interface Request {
  input: string
}
 
interface Response {
  output: string
}
 
const pipeline = new Pipeline<Request, Response>([
 
  function(req: Request, next: (req: Request) => Response): Promise<Response> {
    return next({
      input: req.input.toUpperCase() + '!'  
    })
  }
 
  function(req: Request): Response {
    return {
      output: `Response: ${req.input}`
    }
  }
])
 
const request: Request = {
  input: "Hello world"
}
 
pipeline
  .pipe(request)
  .then(console.log)
 
// { "output": "Response: HELLO WORLD!" }