- Add a
Debounce
graph which wrap elements inOk
orKo
depending on whether they are the first occurence in the given time window. - Add
Flow.debounce
which keep only the fist occurence of an element in the given time window.
- Fix
tut-plugin
bug which addedtut-core
to the POM #28.
- Add cross compilation for scala
2.11.11
and2.12.2
#26 - Upgrade dependencies
- Remove deprecated :
SinkExt.collect
useSink.seq
SourceExt.fromStream(InputStream)
useStreamConverters.fromInputStream
- Deprecate
SourceExt.unfoldPullerAsync
, useSource.unfoldAsync
- Rewrite
EsStream.queryAsStream
usingSource.unfoldAsync
- Switch some dependencie to
Provided
(you need to specify those, they will not be transitively pulled)- In
akka-stream-extensions-postgres
:"org.postgresql" % "postgresql"
- In
akka-stream-extensions-elasticsearch
:"org.elasticsearch" % "elasticsearch"
- In