A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.

A Scala API for Apache Beam and Google Cloud Dataflow.

The Streaming-first HTTP server/module of Akka

Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala

Low-code tool for automating actions on real time data | Stream processing for the users.

Real Time Analytics and Data Pipelines based on Spark Streaming

A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.

🔖 Redis client built on top of Cats Effect, Fs2 and Lettuce

BigPipe streaming for the Play Framework

Quine • a streaming graph • https://quine.io • Discord: https://discord.gg/GMhd8TE4MR

Functional Kafka Streams for Scala

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Iteratees for Cats

Scala lightweight, type-safe, asynchronous driver for neo4j

The Streaming-first HTTP server/module of Apache Pekko

🐰 RabbitMQ stream-based client built on top of Fs2

Lichess' websocket server

🌈 Code samples of advanced features of Http4s in combination with some features of Fs2 not often seen.

A real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.