GitHub topics: streams
rabbitmq/rabbitmq-server
Open source RabbitMQ: core server and tier 1 (built-in) plugins
Language: JavaScript - Size: 207 MB - Last synced at: about 3 hours ago - Pushed at: about 3 hours ago - Stars: 12,900 - Forks: 3,948

crunchypotata/Java-Developer-Coursera
Amazon Junior Software Developer Professional Certificate
Language: Java - Size: 2.54 MB - Last synced at: about 16 hours ago - Pushed at: about 17 hours ago - Stars: 0 - Forks: 0

mithun644/go-chanstreaming
A lightweight library for building concurrent data processing and streaming pipelines using channels
Language: Go - Size: 34.2 KB - Last synced at: about 19 hours ago - Pushed at: about 20 hours ago - Stars: 0 - Forks: 0

bmenegidio/s3-image-optimizer
Script para backup, compressΓ£o e reenvio de imagens otimizadas de um bucket S3 usando Sharp.
Language: TypeScript - Size: 29.3 KB - Last synced at: about 19 hours ago - Pushed at: about 20 hours ago - Stars: 0 - Forks: 0

FRSOURCE/frs-replace
The fastest way to replace any text/file/piped stream content. Shipped with both NodeJS API & CLI out of the box!
Language: TypeScript - Size: 1.32 MB - Last synced at: about 24 hours ago - Pushed at: 1 day ago - Stars: 2 - Forks: 2

smallrye/smallrye-mutiny
An Intuitive Event-Driven Reactive Programming Library for Java
Language: Java - Size: 23.4 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 857 - Forks: 134

google/mug
A small Java 8 library (string manipulation, BiStream, Structured Concurrency, SQL Templates)
Language: Java - Size: 56.1 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 394 - Forks: 67

stdlib-js/streams-node-debug
Transform stream for debugging stream pipelines.
Language: JavaScript - Size: 1.5 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 3 - Forks: 0

stdlib-js/streams-node-from-array
Create a readable stream from an array-like object.
Language: JavaScript - Size: 1.62 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 3 - Forks: 0

jawah/urllib3.future Fork of urllib3/urllib3
urllib3.future is the supercharged low level http client we dreamed of. Support HTTP/1.1, HTTP/2, and HTTP/3 with multiplexed connections! Also WebSocket, and SSE. And DNS over QUIC, TLS, HTTPS and UDP. DNSSEC Protected & Async!
Language: Python - Size: 8.39 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 41 - Forks: 5

Madpeterz/StreamAdmin
A web service to manage selling streams into Secondlife.
Language: PHP - Size: 21.9 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 4 - Forks: 3

xp-framework/core
The XP Framework is an all-purpose, object oriented PHP framework.
Language: PHP - Size: 46.3 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 19 - Forks: 6

sPYROPCS1/Stream-Tools-Awesome
Discover a collection of free streaming tools designed for Windows 2025, perfect for gamers and creators. Enhance your streaming experience with high-quality video and audio, all while enjoying seamless integration with the latest Windows systems. π οΈπ»
Size: 7.81 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 0 - Forks: 0

walkero-gr/aiostreams
All In One streams is a pack of Python scripts for streaming video from various platforms. The target Operating Systems are AmigaOS 4, AmigaOS 3, MorphOS and AROS, but they work on other systems just fine.
Language: Python - Size: 645 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 15 - Forks: 6

ReactiveHTML/rimmel
A Streams-Oriented UI library for the Rx.Observable Universe.
Language: TypeScript - Size: 6.87 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 55 - Forks: 5

thi-ng/umbrella
β± Broadly scoped ecosystem & mono-repository of 208 TypeScript projects (and ~185 examples) for general purpose, functional, data driven development
Language: TypeScript - Size: 229 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 3,595 - Forks: 149

kafbat/kafka-ui
Open-Source Web UI for managing Apache Kafka clusters
Language: Java - Size: 34.9 MB - Last synced at: 4 days ago - Pushed at: 8 days ago - Stars: 1,181 - Forks: 148

micronaut-projects/micronaut-kafka
Integration between Micronaut and Apache Kafka
Language: Java - Size: 15.6 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 89 - Forks: 115

iptv-org/iptv
Collection of publicly available IPTV channels from all over the world
Language: TypeScript - Size: 852 MB - Last synced at: 6 days ago - Pushed at: 7 days ago - Stars: 94,794 - Forks: 3,646

Joshuamaq/tails.js
Tails.js offers a simple way to add utility-first CSS to your projects with just one script tag. Enjoy a comprehensive set of utility classes for layout, colors, and more, all without any setup. ππ
Language: JavaScript - Size: 101 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 0 - Forks: 0

mholt/archives
Cross-platform library to create & extract archives, compress & decompress files, and walk virtual file systems across various formats
Language: Go - Size: 128 KB - Last synced at: 4 days ago - Pushed at: 13 days ago - Stars: 246 - Forks: 21

zio/zio
ZIO β A type-safe, composable library for async and concurrent programming in Scala
Language: Scala - Size: 2.61 GB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 4,219 - Forks: 1,352

clj-commons/byte-streams
A Rosetta stone for JVM byte representations
Language: Clojure - Size: 1.14 MB - Last synced at: 5 days ago - Pushed at: 3 months ago - Stars: 424 - Forks: 32

mmomtchev/ffmpeg
ffmpeg (w/avcpp) bindings for Node.js w/ Streams and async support
Language: TypeScript - Size: 4.18 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 49 - Forks: 5

YunoHost-Apps/streams_ynh
Streams package for YunoHost
Language: Shell - Size: 846 KB - Last synced at: 7 days ago - Pushed at: 8 days ago - Stars: 1 - Forks: 2

feross/multistream
A stream that emits multiple other streams one after another (streams3)
Language: JavaScript - Size: 97.7 KB - Last synced at: 6 days ago - Pushed at: almost 4 years ago - Stars: 294 - Forks: 26

chadangelelli/potamic
Clojure message queue over Redis/KeyDB Streams
Language: Clojure - Size: 263 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 0 - Forks: 0

aol/cyclops
An advanced, but easy to use, platform for writing functional applications in Java 8.
Language: Java - Size: 26.7 MB - Last synced at: 1 day ago - Pushed at: over 2 years ago - Stars: 1,327 - Forks: 138

exini/dicom-streams-js
A streaming and non-blocking API for reading and processing DICOM data
Language: TypeScript - Size: 2.03 MB - Last synced at: 5 days ago - Pushed at: 10 months ago - Stars: 34 - Forks: 5

sindresorhus/execa
Process execution for humans
Language: JavaScript - Size: 2.34 MB - Last synced at: 9 days ago - Pushed at: 30 days ago - Stars: 7,174 - Forks: 238

kostiantyn-matsebora/streamstore
Asynchronous event sourcing.
Language: C# - Size: 1.6 MB - Last synced at: about 5 hours ago - Pushed at: 9 days ago - Stars: 1 - Forks: 0

Riverscapes/PBR
Low Tech Process Based Restoration of Riverscapes
Language: HTML - Size: 68.5 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 2 - Forks: 2

ebonnal/streamable
concurrent & fluent interface for (async) iterables
Language: Python - Size: 4.08 MB - Last synced at: 2 days ago - Pushed at: 10 days ago - Stars: 271 - Forks: 4

ParaGroup/WindFlow
A C++17 Data Stream Processing Parallel Library for Multicores and GPUs
Language: C++ - Size: 48.9 MB - Last synced at: 5 days ago - Pushed at: 4 months ago - Stars: 84 - Forks: 19

Smoren/itertools-ts
TypeScript Iteration Tools Library
Language: TypeScript - Size: 1.34 MB - Last synced at: 1 day ago - Pushed at: 4 months ago - Stars: 66 - Forks: 10

cyrusjetson/streams-demo
Explore java streams in depth
Language: Java - Size: 13.7 KB - Last synced at: 4 days ago - Pushed at: 10 days ago - Stars: 0 - Forks: 0

microsoft/RAG_Hack π¦
Hack Together: RAG Hack | Register, Learn, Hack
Size: 493 MB - Last synced at: 6 days ago - Pushed at: 9 months ago - Stars: 488 - Forks: 109

renggli/dart-rx
Reactive Extensions Library for Dart.
Language: Dart - Size: 635 KB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 12 - Forks: 2

TylorS/typed
Web Applications with Effect-TS
Language: TypeScript - Size: 15.5 MB - Last synced at: 2 days ago - Pushed at: 8 months ago - Stars: 299 - Forks: 15

r-k-b/backpressure-queue
Pipe nodejs streams into an async.queue for parallelisation, get backpressure when the queue is full.
Language: TypeScript - Size: 822 KB - Last synced at: 5 days ago - Pushed at: 6 days ago - Stars: 8 - Forks: 3

kevinoid/promised-read
Read from a stream using Promises, with support for timeouts, cancellation, and several ways to determine how much data to read.
Language: JavaScript - Size: 1.05 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 3 - Forks: 1

an758592/UDJAT
repository containing playlists for multiple video streams from surveillance cameras, easily playable using VLC Media Player.
Size: 12.7 KB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 0 - Forks: 0

SophistSolutions/Stroika
Modern C++ made easy
Language: C++ - Size: 315 MB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 135 - Forks: 10

factorhouse/factorhouse-local
Local environment for running Factor House products (Kpow and Flex) along with supporting infrastructure using Docker Compose
Language: Shell - Size: 17.1 MB - Last synced at: 7 days ago - Pushed at: 13 days ago - Stars: 21 - Forks: 0

StreetStrider/fluh
simple & easy functional reactive library with atomic push strategy
Language: JavaScript - Size: 271 KB - Last synced at: 11 days ago - Pushed at: 21 days ago - Stars: 16 - Forks: 1

zio/zio-ftp
A simple, idiomatic (S)FTP client for ZIO
Language: Scala - Size: 1.63 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 28 - Forks: 13

streamr-dev/hub
Streamr Hub frontend
Language: TypeScript - Size: 169 MB - Last synced at: 3 days ago - Pushed at: 13 days ago - Stars: 33 - Forks: 31

sammwyy/awesome-twitch
A list of awesome twitch streaming tools
Size: 12.7 KB - Last synced at: 5 days ago - Pushed at: 7 months ago - Stars: 24 - Forks: 1

fp4php/functional
PHP Functional Programming library. Monads, common use functions and generic collections.
Language: PHP - Size: 2.02 MB - Last synced at: 14 days ago - Pushed at: 4 months ago - Stars: 195 - Forks: 6

ardislu/csvio
CSV I/O (csvio) is a Node.js library for processing CSV files.
Language: JavaScript - Size: 217 KB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 0 - Forks: 0

factorhouse/kpow
Kpow for Apache Kafka Release Artifacts
Language: Dockerfile - Size: 677 KB - Last synced at: 7 days ago - Pushed at: about 1 month ago - Stars: 48 - Forks: 5

MattiasBuelens/web-streams-polyfill
Web Streams, based on the WHATWG spec reference implementation
Language: TypeScript - Size: 2.39 MB - Last synced at: 5 days ago - Pushed at: about 2 months ago - Stars: 314 - Forks: 31

echocat/java-stream-utils
Utilities for handling Java Streams.
Language: Java - Size: 146 KB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 3 - Forks: 2

Fedecas/KickClipTool
A simple tool to search channels and clips on kick.com
Language: Python - Size: 58.7 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 2 - Forks: 0

joserochadev/link-up
Uma aplicaΓ§Γ£o de videoconferΓͺncia em tempo real para criar e participar de salas de reuniΓ£o virtuais de forma simples e rΓ‘pida.
Language: TypeScript - Size: 139 KB - Last synced at: 16 days ago - Pushed at: 16 days ago - Stars: 0 - Forks: 0

BugSplat-Git/readlines-web
Read files line-by-line using ReadableStreams
Language: TypeScript - Size: 9.77 KB - Last synced at: 4 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

sysulq/rsmq-go
Go implementation of the Message Queue based on Redis Streams.
Language: Go - Size: 494 KB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 4 - Forks: 1

stdlib-js/streams
Standard library streams.
Language: JavaScript - Size: 4.67 MB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 1 - Forks: 0

alexindigo/asynckit
Minimal async jobs utility library, with streams support
Language: JavaScript - Size: 49.8 KB - Last synced at: 10 days ago - Pushed at: almost 7 years ago - Stars: 26 - Forks: 8

esapulkkinen/cifl-math-library
Basic mathematics library
Language: Haskell - Size: 36.9 MB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 12 - Forks: 0

devshawn/kafka-shell
β‘A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.
Language: Python - Size: 82 KB - Last synced at: 8 days ago - Pushed at: over 5 years ago - Stars: 128 - Forks: 12

pickwicksoft/pystreamapi
The Python Stream API Library offering Streams like you know from Java/Kotlin/Scala in Python with some cool extensions
Language: Python - Size: 1.14 MB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 42 - Forks: 5

SpellcraftAI/openai-streams
Tools for working with OpenAI streams in Node.js and TypeScript.
Language: TypeScript - Size: 343 KB - Last synced at: 7 days ago - Pushed at: almost 2 years ago - Stars: 291 - Forks: 27

CodeCavePro/OpenMCDF π¦
Structured Storage .net component - pure C#
Language: C# - Size: 6.39 MB - Last synced at: 8 days ago - Pushed at: over 5 years ago - Stars: 18 - Forks: 9

markrogoyski/itertools-php
PHP Iteration Tools Library
Language: PHP - Size: 969 KB - Last synced at: 1 day ago - Pushed at: 4 months ago - Stars: 148 - Forks: 13

marcoroth/turbo_power
Custom Actions power-pack for Turbo Streams
Language: TypeScript - Size: 1.02 MB - Last synced at: 7 days ago - Pushed at: 9 days ago - Stars: 480 - Forks: 17

crotch-watch/node-core
Understanding Node.js without any other NPM packages.
Language: JavaScript - Size: 55.7 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 0 - Forks: 0

zalando/tailor π¦
A streaming layout service for front-end microservices
Language: JavaScript - Size: 737 KB - Last synced at: 13 days ago - Pushed at: almost 3 years ago - Stars: 1,734 - Forks: 142

QuaNode/beamjs
Private IoB & Enterprise full stack web development framework (BackendJS - ExpressJS - AngularJS - MongoDB)
Language: JavaScript - Size: 661 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 25 - Forks: 1

Arpitmahajan123/Stream-And-Clusters
This project demonstrates the use of Streams and Clusters in Node.js to handle large-scale data processing and optimize performance using multi-core CPUs.
Language: JavaScript - Size: 56.6 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 0 - Forks: 0

mjakubowski84/parquet4s
Read and write Parquet in Scala. Use Scala classes as schema. No need to start a cluster.
Language: Scala - Size: 2.33 MB - Last synced at: 18 days ago - Pushed at: about 1 month ago - Stars: 291 - Forks: 67

rbaltrusch/stream.lua
A lazy iterator-chaining library for Lua similar to the Java Stream API
Language: Lua - Size: 56.6 KB - Last synced at: 22 days ago - Pushed at: 23 days ago - Stars: 0 - Forks: 0

mikepierce/internet-radio-streams
Curated List of Internet Radio Streams
Size: 71.3 KB - Last synced at: 22 days ago - Pushed at: 23 days ago - Stars: 165 - Forks: 10

nodefluent/kafka-streams
equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:
Language: TypeScript - Size: 4.14 MB - Last synced at: 3 days ago - Pushed at: over 2 years ago - Stars: 836 - Forks: 111

stdlib-js/streams-node-debug-sink
Writable stream for debugging stream pipelines.
Language: JavaScript - Size: 1.45 MB - Last synced at: 23 days ago - Pushed at: 24 days ago - Stars: 3 - Forks: 0

AchrafSL/JavaSimpleChatApp_v0_One_Sided
Simple Chat App in Java using Socket Programming and Swing GUI. Great for learning how to build basic networked applications.
Language: Java - Size: 383 KB - Last synced at: 23 days ago - Pushed at: 24 days ago - Stars: 1 - Forks: 0

RivuChk/Jetpack-Compose-MVI-Demo
Demo / Sample Android Project created with Jetpack Compose and MVI Architecture Pattern
Language: Kotlin - Size: 49.2 MB - Last synced at: 13 days ago - Pushed at: over 3 years ago - Stars: 247 - Forks: 33

beardypig/tv-stream-db
A browsable database of live TV streams
Language: Python - Size: 2.42 MB - Last synced at: 6 days ago - Pushed at: over 8 years ago - Stars: 7 - Forks: 2

factorhouse/kpow-local
Run Local Kafka and Kpow with Docker Compose
Size: 1.63 MB - Last synced at: 7 days ago - Pushed at: 28 days ago - Stars: 19 - Forks: 6

kak-tus/ami
Go client to reliable queues based on Redis Cluster Streams
Language: Go - Size: 156 KB - Last synced at: 16 days ago - Pushed at: about 5 years ago - Stars: 32 - Forks: 8

piomin/sample-java-playground
Sample source code for testing Java features like Stream API
Language: Java - Size: 61.5 KB - Last synced at: 28 days ago - Pushed at: 28 days ago - Stars: 4 - Forks: 4

zleonov/unchecked-java
Java streams with checked exception safe lambdas
Language: Java - Size: 555 KB - Last synced at: 28 days ago - Pushed at: 28 days ago - Stars: 0 - Forks: 0

minikin/audio_player_flutter
π§ Apple Music / Tidal Audio Player for Flutter
Language: Dart - Size: 39.8 MB - Last synced at: 1 day ago - Pushed at: about 1 year ago - Stars: 140 - Forks: 21

Valhallaban/rust-cli-chat
Rust Client & Server CLI Chat Application
Language: Rust - Size: 5.86 KB - Last synced at: about 16 hours ago - Pushed at: over 4 years ago - Stars: 7 - Forks: 0

stdlib-js/streams-node-split
Transform stream which splits streamed data.
Language: JavaScript - Size: 1.6 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 2 - Forks: 0

stdlib-js/streams-node-from-circular-array
Create a readable stream from a circular array-like object.
Language: JavaScript - Size: 1.62 MB - Last synced at: 5 days ago - Pushed at: about 1 month ago - Stars: 2 - Forks: 0

carlreid/StreamMaster
A powerful M3U proxy and stream management platform for Plex DVR, Emby, Jellyfin Live TV (and more)
Language: C# - Size: 92.9 MB - Last synced at: 29 days ago - Pushed at: 29 days ago - Stars: 134 - Forks: 62

Touffy/client-zip
A client-side streaming ZIP generator
Language: TypeScript - Size: 441 KB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 386 - Forks: 27

ksgerastenok/java
Basic java examples.
Language: Java - Size: 67.9 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

smnorris/fwapg
PostgreSQL tools for working with British Columbia's Freshwater Atlas
Language: PLpgSQL - Size: 9.52 MB - Last synced at: 7 days ago - Pushed at: about 1 month ago - Stars: 9 - Forks: 4

lmammino/streams-workshop
A FREE and open-source workshop about Node.js Streams
Language: JavaScript - Size: 7.7 MB - Last synced at: about 1 month ago - Pushed at: about 1 year ago - Stars: 272 - Forks: 33

dbrattli/aioreactive
Async/await reactive tools for Python 3.10+
Language: Python - Size: 503 KB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 388 - Forks: 26

mreiche/python-streams
Java-like streams for Python
Language: Python - Size: 96.7 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

m1k1o/go-transcode
On-demand transcoding origin server for live inputs and static files in Go using ffmpeg. Also with NVIDIA GPU hardware acceleration.
Language: Go - Size: 295 KB - Last synced at: about 1 month ago - Pushed at: 6 months ago - Stars: 249 - Forks: 41

mholt/archiver π¦
DEPRECATED. Please use mholt/archives instead.
Language: Go - Size: 536 KB - Last synced at: 28 days ago - Pushed at: 7 months ago - Stars: 4,414 - Forks: 391

getify/asynquence π¦
Asynchronous flow control (promises, generators, observables, CSP, etc)
Language: JavaScript - Size: 503 KB - Last synced at: 26 days ago - Pushed at: over 5 years ago - Stars: 1,743 - Forks: 148

MattiasBuelens/wasm-streams
Bridging between web streams and Rust streams using WebAssembly
Language: Rust - Size: 327 KB - Last synced at: about 1 month ago - Pushed at: 8 months ago - Stars: 171 - Forks: 12

provectus/kafka-ui
Open-Source Web UI for Apache Kafka Management
Language: Java - Size: 29 MB - Last synced at: about 1 month ago - Pushed at: 11 months ago - Stars: 10,773 - Forks: 1,272

stdlib-js/streams-node-join
Transform stream which joins streamed data.
Language: JavaScript - Size: 1.74 MB - Last synced at: 5 days ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

stdlib-js/streams-node-inspect-sink
Writable stream for inspecting streamed data.
Language: JavaScript - Size: 1.62 MB - Last synced at: 5 days ago - Pushed at: about 1 month ago - Stars: 2 - Forks: 0
