pipeline.ts
v1.0.2
Published
Generic request/response pipeline for TypeScript
Downloads
4
Maintainers
Readme
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!" }