streamqueue
Stream processor
Manages and pipes queued streams sequentially to preserve content order.
Pipe queued streams progressively.
63 stars
6 watching
4 forks
Language: TypeScript
last commit: 8 months ago
Linked from 1 awesome list
alferov/awesome-gulpRelated projects:
| Repository | Description | Stars |
|---|---|---|
 nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
 composewell/streamly | A high-performance Haskell library providing functional programming abstractions and concurrency capabilities | 873 |
 nextflow-io/rnaseq-nf | A pipeline for quantifying genomic features from short read data using Nextflow and various software components. | 74 |
 streampunk/node-red-contrib-dynamorse-core | A software framework that enables the creation of streaming workflows on commodity IT systems using reactive streams and NMOS registration/discovery. | 45 |
 robinjoseph08/redisqueue | A Redis-based producer-consumer system for handling messages with guaranteed delivery and visibility timeouts. | 131 |
 nessos/streams | A lightweight library for building efficient data pipelines using functional programming concepts | 383 |
 sindresorhus/p-pipe | Creates a reusable pipeline of promise-returning functions to compose and chain together multiple asynchronous operations. | 122 |
 weblyzard/streaming-sparql | Provides a robust, incremental processing of streaming results from SPARQL servers. | 6 |
 maki-nage/makinage | Stream Processing Library and Framework | 38 |
 nickolasburr/rng | Streams input from a file or stdin to stdout, with customizable line ranges. | 31 |
 hortonworks/streamline | A toolset for building and deploying real-time data processing applications using various streaming engines and frameworks. | 165 |
 gazette/core | Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms | 723 |
 hasura/pgdeltastream | A service to stream Postgres changes over websockets using logical replication | 254 |
 bkirwi/coast | A streaming data processing framework with strong ordering and exactly-once semantics | 60 |
| streampunk/beamcoder | Provides Node.js bindings to FFmpeg for media processing and manipulation | 401 |