Streamz provides combinator libraries for integrating Functional Streams for Scala (FS2), Akka Streams and Apache Camel endpoints. They integrate
- Apache Camel with Akka Streams: Camel endpoints can be integrated into Akka Stream applications with the Camel DSL for Akka Streams.
- Apache Camel with FS2: Camel endpoints can be integrated into FS2 applications with the Camel DSL for FS2.
- Akka Streams with FS2: Akka Stream
Source
s,Flow
s andSink
s can be converted to FS2Stream
s,Pipe
s andSink
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.