Data streaming

Lumelight 3D — Moonlight-based glasses-free 3D streaming for Leia lightfield panels (Lume Pad 2, Red Magic 3D Explorer)

Low-Latency 720p 60 FPS PC Game Streaming on a Stock, Unmodded Nintendo Switch Lite

Template for streaming IIoT sensor readings into Apache Iceberg on Amazon S3 Tables with Kinesis, Firehose, a Go transform, and Lake Formation cross-account sharing.

Ultra-fast, lightweight pure-Rust stream processing engine for IoT & edge analytics (by I-Dacs Labs)

Telemetry as agentic short-term memory. One binary: OTLP in, Arrow blocks out, sub-15ms queries, an MCP endpoint your agent can actually reason over.

Fastest open-source data quality engine. Polars streaming + SQL pushdown. 259M rows in 1.5s.

Onchain listeners and a technical reference for the FOMO trading app on Solana and Robinhood Chain

Freelens extension for Apache Kafka

Distributed microservices architecture with OpenTelemetry tracing, Kafka messaging, and auto/manual instrumentation, visualized in Uptrace.

Morpho Blue + MetaMorpho Substreams: markets, positions, vaults (Ethereum + Base). Own pack beyond StreamingFast stub.

Stream any video (movie/series) on your PSP! Mini movie player whereever you go!

Local Windows/ComfyUI controller for continuous MiniMax H3 reference-to-video generation. It turns short Ref2V clips into a viewer-aware HTTP stream and adds live prompt control, character references, story continuation, LoRAs, adaptive quality, optional SageAttention, and a continuous external music bed.

Excel RTD-style live data add-in built with Office.js streaming custom functions over WebSocket. Includes a mock WebSocket server for testing.

Institutional-grade market data infrastructure: converts noisy, multi-venue exchange feeds into a validated, sub-microsecond canonical stream with cryptographic auditability and zero silent drops.

A native implementation of the Durable Streams protocol for Rivet Actors

Scrape the Ottawa Public Library UI + publish with MQTT

Ridiculously fast Markdown for React and AI. Streaming-native renderer that caches settled code lines, table rows, and list items so growing LLM output does not re-parse finished work.

Kafka ridesharing implementation

Python runtime for consuming PostgreSQL logical replication directly from WAL

Format- and source-agnostic ingestion framework: a common execution runtime for turning record-oriented data sources into typed columnar data. Rust core, Python bindings; adapters live in separate packages.

High performance message broker in go