These are chat archives for akkadotnet/AkkaStreams

9th
Mar 2017
David Hoerster
@DavidHoerster
Mar 09 2017 11:59
Hi everyone! Does anyone know of an example of joining reactive streams (using a window I suppose) or if that functionality is on the roadmap for Akka Streams?
Konrad `ktoso` Malawski
@ktoso
Mar 09 2017 12:00
hm? it is an reactive streams impl
David Hoerster
@DavidHoerster
Mar 09 2017 12:08
I'll take a look - thanks. I'm trying to see how to enrich a stream with perhaps a second stream. So, for example, if I have a stream of real-time game stats coming in, I may have a playerId. I may want to enrich that incoming stream with info about the player from the MasterPlayer stream (full name, for instance). It's a contrived example, but I'm really trying to enrich incoming streams. Spark Streaming and Azure Stream Analytics allow for this -- just curious how this is done or could be done with Akka Streams.
Konrad `ktoso` Malawski
@ktoso
Mar 09 2017 12:59
Merge etc, "fan in stages"
// PS: I'm from the JVM impl, but I guess the .net port has the same :) specific questions should get you better answers :)
or just a mapAsync to enrich stuff, depends what you want to do really