Awesome Open Source

Programming Languages

Search results for scala reactive streams

reactive-streams x

52 search results found

Monix ⭐ 1,930

Asynchronous, Reactive Programming for Scala and Scala.js.

Elastic4s ⭐ 1,628

Elasticsearch Scala Client - Reactive, Non Blocking, Type Safe, HTTP Client

Alpakka Kafka ⭐ 1,417

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

The Scala HTTP client you always wanted!

Alpakka ⭐ 1,259

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Akka Grpc ⭐ 427

Kafka-based message queue

Airstream ⭐ 219

State propagation and event streams with mandatory ownership and no glitches

Play Ws ⭐ 217

Standalone Play WS, an async HTTP client with fluent API

Eventstore.jvm ⭐ 217

Event Store JVM Client

A lightweight Reactive Streams Infrastructure Toolkit for Scala.

Akka Streams In Practice ⭐ 82

Import data from CSV files to Cassandra using Akka Streams

Asynchronous database access for Scala and Java

Intro To Akka Streams ⭐ 65

Monix Connect ⭐ 60

A set of connectors for Monix. 🔛

Reactor Scala Extensions ⭐ 52

A scala extension for Project Reactor's Flux and Mono

Future Streams ⭐ 47

Scala Future-based implementation of Reactive Streams

Interop Reactive Streams ⭐ 47

Interoperability Layer Between ZIO and Reactive Streams

Incubator Pekko Connectors ⭐ 47

Apache Pekko Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.

Http4s Netty ⭐ 40

Http4s on pure netty

Orientdb Scala Stream ⭐ 35

OrientDB scala reactive-streams (akka streams) library for non-blocking and live queries.

Aws Spi Akka Http ⭐ 33

This is an alternative implementation of the new aws java sdk v2 non-blocking async SPI. It provides an alternative to the built-in Netty implementation based on akka-http.

Toketi Iothubreact ⭐ 31

Akka Stream library for Azure IoT Hub

Spark As Service Using Embedded Server ⭐ 30

This application comes as Spark2.1-as-Service-Provider using an embedded, Reactive-Streams-based, fully asynchronous HTTP server

Incubator Pekko Grpc ⭐ 30

Apache Pekko gRPC

FunDA, a functional data processing library to supplement FRM (Functional-Relational-Mapper)

Reactivecouchbase Rs Core ⭐ 27

New ReactiveCouchbase driver using reactive-streams

Monitor akka applications with reactive streams

Plant Simulator ⭐ 24

Power Plant simulator service that can ramp up and down power producing units

Incubator Pekko Connectors Kafka ⭐ 17

Apache Pekko Kafka Connector - Pekko-Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.

Reactive Streams End To End Example ⭐ 16

A reactive streams end-to-end example in Scala.

Scala Docker ⭐ 13

Docker client for Scala

Reactive Streams With Monix ⭐ 11

Import data from CSV files to Cassandra using Monix Reactive Streams

Kinesis Stream ⭐ 10

Scala based wrapper for Kinesis Consumer Library which exposes the stream as an Akka Streams Source

Mongodb S3 Stream Example ⭐ 9

MongoDB collection backup and restore to/from Amazon S3 using Akka Streams and Alpakka.

Reactive Streams Telemetry ⭐ 9

Amqp Akka Streams ⭐ 8

A library that allow you to leverage Akka Streams while reading or writing messages to AMQP broker.

Teleporter ⭐ 8

Reactive Streams distributed datapipeline for data process. Now support kafka,jdbc,kudu,elasticsearch,hdfs.etc

Reactive Streams ⭐ 7

reactive stream examples for jcconf 2016 presentation

Reactive Nakadi ⭐ 7

Reactive streams for the Nakadi distributed event bus

Reactive Telegrambot ⭐ 7

Scala & Reactive Streams wrapper for Telegram Bots API

Fast Reactive Fs2 ⭐ 6

Fast jvm-only implementation of the reactive streams for fs2.

Akka Http Backpressure ⭐ 6

Slides and code for reactive streams, backpressure, akka streams and akka http talk

JMS in the terms of Reactive Streams

Toketi Iothub To Cassandra ⭐ 5

Azure IoT connector to feed connected devices telemetry to Apache Cassandra

Gnip Consumer ⭐ 5

Consuming Gnip streaming API using Akka HTTP / Streams 2.4.2

Slick3 Test ⭐ 5

Study into Slick3 and Reactive Slick (reactive-streams) and interoperability with RxScala/RxJava using the adapter library

Streams Tutorial ⭐ 5

An in-depth tutorial that guides you through building a reactive streams application using Scala, Akka and Akka-Streams with monitoring using Kamon and a StatsD/Graphite/Grafana Docker image.

Related Searches

Scala Sbt (4,178)

Scala Spark (3,279)

Scala Akka (2,120)

Java Scala (1,794)

Scala Play Framework (1,309)

Plugin Scala (1,079)

Scala Kafka (969)

Scala Functional Programming (942)

Scala Scalajs (887)

Scala Apache (705)

1-52 of 52 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2025 Awesome Open Source. All rights reserved.