in-process pipelines for JavaScript like Twitter Storm