stream fp functional-programming streaming-computation scala

1786 470 192

analytics memory-database stream spark scale snappydata transaction

988 190 41

client effects lettuce cats-effect scala redis streaming stream fs2

171 39 25

real-time event-hubs structured-streaming spark-streaming apache stream scala spark microsoft eventhubs streaming ingestion apache-spark databricks azure connector bigdata continuous kafka

131 117 31

rabbitmq amqp-client amqp rabbitmq-client streaming stream fs2

108 38 28

rabbitmq amqp-client amqp rabbitmq-client streaming stream fs2

66 28 18

aws-sdk zio connector stream scala sqs functional-programming

57 16 12

pipe systemprocess prox redirection stream process library scala

46 3 4

client effects lettuce cats-effect scala redis streaming stream fs2

52 10 7

parse xml substream stream handler

19 1 1

akka stream recovery snapshot

7 1 1

pdf scodec scala stream fs2

3 1 2

reactive-programming stream scalajs

0 0 1