Re: [akka-user] Akka Streams Transformer

Thanks! That did the trick. I was digging down the implementation, but wasn't able to find out the correct usage :) Am Sonntag, 16. November 2014 21:32:02 UTC+1 schrieb √: > > > geoSource ~> Flow[LocationUpdate].transform("gridcell", () => > GridCellTransformer(…)).transform("compress", () => ne

Re: [akka-user] Akka Streams Transformer

geoSource ~> Flow[LocationUpdate].transform("gridcell", () => GridCellTransformer(…)).transform("compress", () => new Compressor(…)) Does that help? :-) On Sun, Nov 16, 2014 at 8:44 PM, Muki wrote: > Hi, > > I'm currently trying to build a real-time geo-indexing application with > akka streams.

[akka-user] Akka Streams Transformer

Hi, I'm currently trying to build a real-time geo-indexing application with akka streams. In order to index my location updates I have to buffer them in a Transformer and map them to a new value when enough events where received. My current implementation is like this val geoSource: Source[Loc