fast-reactive-fs2

Implementation of the reactive streams for fs2.

This version is not cross-platform, but faster than official module:

Benchmark                                      Mode  Cnt      Score      Error  Units
ReadOneMillionNumbers.dokworkStreamSubscriber  avgt   25    56.017 ±    1.877  ms/op
ReadOneMillionNumbers.fs2StreamSubscriber      avgt   25  3222.676 ± 1143.118  ms/op

Installation

libraryDependencies += "ru.dokwork" %% "fast-reactive-fs2" % "0.1.1"

Usage

val publisher: Publisher[A] = ???
val stream: fs2.Stream[F, A] = StreamSubscriber.subscribe[F, A](publisher)