streamqueue

Stream processor

Manages and pipes queued streams sequentially to preserve content order.

Pipe queued streams progressively.

GitHub

63 stars
6 watching
4 forks
Language: TypeScript
last commit: about 2 years ago
Linked from 1 awesome list


Backlinks from these awesome lists:

Related projects:

RepositoryDescriptionStars
nodefluent/kafka-streamsA Node.js library implementing Kafka Streams functionality for stream state processing and table representation.831
composewell/streamlyA high-performance Haskell library providing functional programming abstractions and concurrency capabilities873
nextflow-io/rnaseq-nfA pipeline for quantifying genomic features from short read data using Nextflow and various software components.74
streampunk/node-red-contrib-dynamorse-coreA software framework that enables the creation of streaming workflows on commodity IT systems using reactive streams and NMOS registration/discovery.45
robinjoseph08/redisqueueA Redis-based producer-consumer system for handling messages with guaranteed delivery and visibility timeouts.131
nessos/streamsA lightweight library for building efficient data pipelines using functional programming concepts383
sindresorhus/p-pipeCreates a reusable pipeline of promise-returning functions to compose and chain together multiple asynchronous operations.122
weblyzard/streaming-sparqlProvides a robust, incremental processing of streaming results from SPARQL servers.6
maki-nage/makinageStream Processing Library and Framework38
nickolasburr/rngStreams input from a file or stdin to stdout, with customizable line ranges.31
hortonworks/streamlineA toolset for building and deploying real-time data processing applications using various streaming engines and frameworks.165
gazette/coreEnables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms723
hasura/pgdeltastreamA service to stream Postgres changes over websockets using logical replication254
bkirwi/coastA streaming data processing framework with strong ordering and exactly-once semantics60
streampunk/beamcoderProvides Node.js bindings to FFmpeg for media processing and manipulation401