[akka-user] Re: [Akka-Streams] Want to always receive latest element in Sink

2018-01-24 Thread Tal Pressman
Hi, I don't know if there is any built-in graph that does this, but you can implement your own graph stage for this fairly easily. You just need a stage with an Option[Value], in the onPush you either push the value downstream or store it, and in any case you pull. In the onPull you just have

[akka-user] [Akka-Streams] Want to always receive latest element in Sink

2018-01-24 Thread saloniv
Hello, We are having a requirement that if a consumer is slower than producer then discard all the elements that cannot be consumed and whenever the consumer gets ready, feed the latest element from producer. We tried an approach as follows: Source.actorRef(0, OverflowStrategy.dropHead)

[akka-user] Re: Swakka - a new extension to akka-http for Swagger/OpenApi

2018-01-24 Thread Jeremy Townson
Hi Akka users, This is an update about Swakka, an addon for generating OpenApi/Swagger docs with Akka-Http. I introduced Swakka in August last year. Back then it was new, unstable and I recommended people not to use it. Yesterday, I cut a v0.5 release. Whilst the library does not cover

[akka-user] Re: decorate actor events / events processing as a way to implement open tracing capabilities

2018-01-24 Thread Rob Crawford
And it looks like they literally just released version 1.0! On Tuesday, January 23, 2018 at 7:32:29 AM UTC-5, daz...@gmail.com wrote: > > > On Monday, 22 January 2018 14:07:22 UTC, Rob Crawford wrote: >> >> Have you tried Kamon (kamon.io)? They're in flux getting 1.0 done, but >> 1.0 is supposed