integration reactive akka messaging akka-streams-connectors reactive-streams akka-stream

1127 570 258

cats-effect reactive-streams reactivex scala typelevel fp functional-programming cats monix reactive-programming

1694 217 86

kafka reactive reactive-streams akka kafka-client scala kafka-connector java akka-streams

1265 375 92

reactive-streams elasticsearch scala http circe rest-api

1512 610 261

akka-http synchronous monix zipkin-brave scalaz reactive-streams zipkin httpclient scala distributed-tracing uri http asynchronous okhttp cats interpolator

999 164 94

cassandra reactive reactive-streams phantom datastax-enterprise scala

1035 185 30

streaming akka-http reactive-streams akka rpc scala java grpc reactive

335 83 55

dom-manipulation scalajs reactive-streams scala-js scala ui functional-reactive-programming

255 18 7

playframework reactive reactive-streams http-client scala java asynchttpclient asynchronous

182 61 34

cats async pulsar reactive monix scalaz reactive-streams scala akka-streams

162 29 14

kafka reactive-streams akka scala java message-queue

167 24 4

clickhouse reactive reactive-streams akka scala

72 15 8

scalajs reactive-streams functional-reactive-programming state-management scala-js scala

62 8 4

scala-extension reactive-streams flux smono reactor-core sflux mono reactive reactor reactive-programming scala reactor-scala-extensions project-reactor java

43 14 10

scala orientdb akka reactive-streams

35 4 2

mongodb sqs monix aws google-cloud-platform redis dynamodb connectors s3 reactive-streams parquet akka hdfs scala google-cloud-storage

30 10 7

akka-http aws-java-sdk-v2 reactive-streams

27 8 7

couchbase async reactive-programming reactive-streams non-blocking scala akka-streams nosql json

24 12 5

scala akka reactive-streams serial

24 1 1

alpakka cassandra reactive-streams akka azure-iot iot scala java akka-streams

23 11 2