Skip to content

Fast jvm-only implementation of the reactive streams for fs2.

License

Notifications You must be signed in to change notification settings

dokwork/fast-reactive-fs2

Repository files navigation

fast-reactive-fs2

Build Status Coverage Status Download

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)

About

Fast jvm-only implementation of the reactive streams for fs2.

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages