Search *

raquo/xstream.scala

Scala.js interface to XStream.js, a simple functional reactive stream library

Scala (JVM): 2.11 2.12

Scala.js: 0.6

reactive-programming stream scalajs

0 0 1

profunktor/fs2-rabbit

RabbitMQ stream-based client built on top of Fs2

Scala (JVM): 2.11 2.12 2.13

amqp-client amqp fs2 rabbitmq-client rabbitmq stream streaming

66 28 18

commodityvectors/pipeline

Akka stream persistent pipeline

Scala (JVM): 2.11 2.12

akka stream recovery snapshot

7 1 1

vigoo/prox

A Scala library for working with system processes

Scala (JVM): 2.12

prox redirection library systemprocess scala stream process pipe

9 2 3

gvolpe/fs2-rabbit

RabbitMQ stream-based client built on top of Fs2

Scala (JVM): 2.11 2.12

amqp-client amqp fs2 rabbitmq-client rabbitmq stream streaming

66 28 18

gvolpe/fs2-redis

Redis client built on top of Cats Effect, Fs2 and Lettuce

Scala (JVM): 2.12

lettuce effects cats-effect fs2 scala stream client redis streaming

52 10 7

profunktor/redis4cats

:floppy_disk: Redis client built on top of Cats Effect, Fs2 and Lettuce

Scala (JVM): 2.12 2.13

lettuce effects cats-effect fs2 scala stream client redis streaming

86 13 8

functional-streams-for-scala/fs2

Compositional, streaming I/O library for Scala

Scala (JVM): 2.11 2.12 2.13

Scala.js: 0.6

fp scala stream streaming-computation functional-programming

1486 378 146

dylemma/xml-spac

Handle streaming XML data with declarative, composable parsers

Scala (JVM): 2.10 2.11 2.12

xml handler stream substream parse

6 0 1

snappydatainc/snappydata

SnappyData - The Spark Database. Stream, Transact, Analyze, Predict in one cluster

Scala (JVM): 2.11

snappydata scale transaction spark stream memory-database analytics

914 178 44

azure/azure-event-hubs-spark

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Scala (JVM): 2.11

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

112 87 26

zio/zio-sqs

ZIO-powered client for AWS SQS

Scala (JVM): 2.12

sqs scala stream functional-programming zio aws-sdk connector

28 7 5

Sorting

Filters

raquo/xstream.scala

profunktor/fs2-rabbit

commodityvectors/pipeline

vigoo/prox

gvolpe/fs2-rabbit

gvolpe/fs2-redis

profunktor/redis4cats

functional-streams-for-scala/fs2

dylemma/xml-spac

snappydatainc/snappydata

azure/azure-event-hubs-spark

zio/zio-sqs