Streamz
Fork Information
This is a fork from Streamz repo. Since the Maven publish of original repo is broken, this repo add changes to publish the builds to Maven Central.
If you want to use these build, no need to add resolvers into build.sbt. And use me.binwang.streamz instead of com.github.krasserm.
Use with caution: There is no guarantee the builds will be updated and maintained.
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
Sources,Flows andSinks can be converted to FS2Streams,Pipes andSinks, respectively, and vice versa with Stream converters.
Dependencies
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 |
Latest milestone release for FS2 1.0.x
val streamzVersion = "0.10-M2"
Latest stable release for FS2 0.10.x
val streamzVersion = "0.9.1"
Latest stable release for FS2 0.9.x
val streamzVersion = "0.8.1"
Documentation
Streamz 0.13
Streamz 0.10-M2
Streamz 0.9.1
Streamz 0.8.1
API docs
Latest version
Older versions
Streamz 0.10-M2
Not published. Run sbt unidoc on tag 0.10-M2 for generating 0.10 API docs.
Streamz 0.9.1
Not published. Run sbt unidoc on branch r-0.9 for generating 0.9 API docs.
Streamz 0.8.1
Not published. Run sbt unidoc on branch r-0.8 for generating 0.8 API docs.
