0.11

• Token throttle flow #166 thanks to @andreas-schroeder
• Upgrade to Akka 2.6 and drop Scala 2.11 #178 thanks to @dsebban

Many updates

• concat should process multiple elements concurrently thanks to @matankdr
• Allow rate limiter to spill over (#125)
• Allow passing timeout parameter to unfoldFlow (#120) thanks to @liff
• PagedSource thanks to @otto-ringhofer
• DelayFlow optimization thanks to @jbgi
• Add keep alive from buffer graph stage thanks to @radusw
• Various dependency updates thanks to @cchantep
• Tests to verify that killswitch also works when Retry is stuck thanks to @hochgi
• PassThrough Flow thanks to @tkroman
• By-name version of Source.repeat thanks to @tkroman
• Add maxElements and maxDuration parameters to AccumulateWhileUnchanged thanks to @LysanderGG
• eagerCancel parameter for PartitionWith. (#150) thanks to @TomasMikula
• FeedbackLoop operator, a deadlock-free way of introducing cycles thanks to @TomasMikula
• Drop Akka 2.4 support thanks to @TomasMikula
• Many infrastructure improvements thanks to @2m
• Scala 2.13 support thanks to @liff

Delays, RateLimiting and Valve inspection.

• DelayFlow with flexible DelayStrategy implementation #89
• Add .getMode to the valve to be able to check the current state #116
• Add an IntervalBasedRateLimiter #101

Scala API docs: https://developer.lightbend.com/docs/api/akka-stream-contrib/0.9/akka/stream/contrib/index.html

Removing the XML parser

The XML parser has been moved to Alpakka

Scala API docs: https://developer.lightbend.com/docs/api/akka-stream-contrib/0.8/akka/stream/contrib/index.html

Moves, Fixes and TimeWindow

• AMQP, MQTT and Cassandra have been moved to Alpakka
• Bugfixes for Valve (thanks to @regis-leray)
• Pulse stage and TimeWindow flow (thanks to @marcin-rzeznicki)

Scala API docs: https://developer.lightbend.com/docs/api/akka-stream-contrib/0.7/akka/stream/contrib/index.html

Various small updates

• Deprecate Accumulate in favour of scan and drop(1)
• MQTT: Optional authentication
• Cassandra: Extend timeout
• Add support for Scala 2.12
• Upgrade to akka 2.4.12
• Add Valve to control a flow (open/close)

All closed tickets

Scala API docs: https://developer.lightbend.com/docs/api/akka-stream-contrib/0.6/akka/stream/contrib/index.html

Artifacts

// various graph stages
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib" % "0.6"

// amqp connector
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-amqp" % "0.6"

// mqtt connector
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-mqtt" % "0.6"

// cassandra connector
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-cassandra" % "0.6"

// streaming xml parser
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-xmlparser" % "0.6"

Cassandra, Streaming XML and Unfold

This release includes two new artifacts:

• Cassandra connector that transforms ResultSet to Akka Streams Source #53, thanks to @atamborrino
• Streaming XML parser #64, which architecture is eplained in detail in Custom Flows: Parsing XML (part I)

And a new Unfold stage #32, thanks to @hochgi

All closed tickets

Artifacts

// various graph stages
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib" % "0.4"

// amqp connector
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-amqp" % "0.4"

// mqtt connector
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-mqtt" % "0.4"

// cassandra connector
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-cassandra" % "0.4"

// streaming xml parser
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-xmlparser" % "0.4"

AMQP, MQTT, File connectors, Timing and Retry stages

This release includes two new artifacts:

• AMQP connector using RabbitMQ client library #42
• MQTT connector using Paho client library #40

Also a couple of new graph stages have been added to the collection:

• Timing measurement stage #44. Moved from Akka. Thanks goes to @naferx
• Retry Flows #26. Thanks goes to @hochgi
• File tail source #38
• Directory watch source #35

All closed tickets

Artifacts

// various graph stages
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib" % "0.3"

// amqp connector
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-amqp" % "0.3"

// mqtt connector
libraryDependencies += "com.typesafe.akka" %% "akka-stream-contrib-mqtt" % "0.3"