Streamz provides combinator libraries for integrating Functional Streams for Scala (FS2), Akka Streams and Apache Camel endpoints. They integrate
Source
s, Flow
s and Sink
s can be converted to FS2 Stream
s, Pipe
s and Sink
s, respectively, and vice versa with Stream converters.Streamz artifacts are available for Scala 2.12 and 2.13 at:
resolvers += Resolver.bintrayRepo("streamz", "maven")
val streamzVersion = "0.13"
libraryDependencies ++= Seq(
"com.github.krasserm" %% "streamz-camel-akka" % streamzVersion,
"com.github.krasserm" %% "streamz-camel-fs2" % streamzVersion,
"com.github.krasserm" %% "streamz-converter" % streamzVersion,
)
Streamz version | fs2 version |
---|---|
(not yet) | 3.0.x |
0.13 | 2.x |
0.10-M2 | 1.x |
0.9.1 | 0.10.x |
0.8.1 | 0.9.x |
val streamzVersion = "0.10-M2"
val streamzVersion = "0.9.1"
val streamzVersion = "0.8.1"
Not published. Run sbt unidoc
on tag 0.10-M2
for generating 0.10 API docs.
Not published. Run sbt unidoc
on branch r-0.9
for generating 0.9 API docs.
Not published. Run sbt unidoc
on branch r-0.8
for generating 0.8 API docs.