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

1284 139 41

elasticsearch circe rest-api http scala reactive-streams

1218 487 200

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

1028 287 65

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

568 72 17

mongodb akka driver reactive akka-streams reactive-streams

19 5 5

scala orientdb akka reactive-streams

35 4 2

rethinkdb scala driver reactive akka-streams reactive-streams

3 0 1

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

140 16 16

loadbalancing exchange load-balancer akka-http scala akka-streams reactive-streams

0 0 1

zookeeper client akka reactive-streams

6 0 1

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

810 360 163

scala iteratee-io play-framework akka-streams reactive-streams fs2

3 1 1

cassandra datastax-enterprise phantom scala reactive reactive-streams

973 183 29

azure eventhubs telemetry akka-streams reactive-streams

2 1 5

functional-programming play-iteratees slick scala scalaz-streams-fs2 reactive-streams

19 2 1

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

17 4 4

scala akka reactive-streams serial

24 1 1

dicom scala dcm4che akka-streams reactive-streams

3 0 2

dicom akka-streams reactive-streams scala

0 1 3

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

14 2 2