ZIO — A type-safe, composable library for async and concurrent programming in Scala

Read and write Parquet in Scala. Use Scala classes as schema. No need to start a cluster.

A simple, idiomatic (S)FTP client for ZIO

An example application leveraging zio-streams and Redisson library to consume and produce events to Redis streams.

Portals is a framework for stateful serverless apps, unifying dataflow streaming with actors

A Kafka mirroring service based on Akka Streams Kafka

Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.

Pure Scala fully non-blocking and asynchronous FTP client, implemented from scratch using Akka.

Scala http streaming examples

Streaming Data Access and Modification for BSON and JSON encoded documents

A ZIO wrapper around the Datastax Cassandra driver

window wordcount aggregations on streaming text sources

live support chat server (currently on hold)

JMS connectors for FS2 streams

Apache Streams ActivityPub Server

fs2 compared to Akka Stream