zio-streams
There are 28 repositories under zio-streams topic.
fancellu/zio-restful-webservice
ZIO 2.0 Restful webservice example using zio, zio-http, zio-json, quill, H2, twirl, zio-streams, zio-cache, zio-logging, zio-actors, zio-spark, openai, DallE
laserdisc-io/tamer
Standalone alternatives to Kafka Connect Connectors
kaizen-solutions/virgil
A purely functional Cassandra client built on top of the Datastax Java Driver supporting a variety of effect systems like ZIO & Cats-Effect supporting both Scala 2 & 3
zio/zio-ftp
A simple, idiomatic (S)FTP client for ZIO
otobrglez/dojodis
High-performance Redis server implemented in Scala with ZIO.
kensuio-oss/redis-streams-zio
An example application leveraging zio-streams and Redisson library to consume and produce events to Redis streams.
jczuchnowski/zio-pulsar
Apache Pulsar client for Scala with ZIO and ZIO Streams integration.
epifab/cql4s
Cassandra typesafe DSL for pure functional Scala supporting cats effect, fs2, ZIO
mvillafuertem/scalcite
Scalcite is a library to query 💬 and update ✏️ JSON data 📄
mvillafuertem/scala
🤓 Examples Advanced 🧐 Projects Akka 🚀 ZIO ⚡️ Algorithms 😼 Cats
ollls/zio-quartz-h2
ZIO2 native, asynchronous Java NIO based implementation of http/2 packet streaming server with TLS encryption implemented as scala ZIO2 effect. Direct native translation of ZIO ZStream chunks into http2 packets (inbound and outbound).
mbannour/zio-mongoDB
ZIO wrapper for MongoDB Reactive Streams Java Driver and MongoDb scala Driver
googley42/zio-dynamodb-example
An example of ZIO integration with AWS java SDK. Shows ZIO Streaming of a paged query.
pawelkaczor/telemetry-reports
Sample app combining zio-streams, akka-streams, zio-prelude (Associative, Identity type classes)
makiftutuncu/tweet-tracker
An application for streaming tweets containing a search term on Twitter in real time for a predefined duration or number of tweets
mtumilowicz/scala-zio2-zstream-workshop
Introduction to streaming using zio (ZStream).
oleg-korolenko/basket-score-streaming
Score events streaming pipeline
AnyMindGroup/zio-pubsub
Google Cloud Pub/Sub client for ZIO and ZIO Streams
EtaCassiopeia/api-aggregation-service
Scala, ZIO, Http4s, Sttp
EtaCassiopeia/tvi-charging-back-office
Scala, ZIO, Http4s
kaizen-solutions/circe-zio-streams
ZIO Streams integration for streaming json parsing via Circe + Jawn
ernestochero/sensor_statistics_challenge
code challenge
gurghet/scala-vns
Variable Neighborhood Search library for scala
mtumilowicz/scala-zio2-grpc-workshop
Introduction to proto-buffers and gRPC based on ZIO approach.
otobrglez/frogger
frogger is high-performance transit lookup server written as part of transit-lang-cmp language comparison challenge.
Teroaz/scala-zio
School Project in "Functional Programming" module