Hi! I'm somewhat new to akka-streams and trying to find the best way to
express this flow:
Let's say I have a stream of messages of type M for
case class M(id: Int, val: String)
and I have a source and some sink:
MSource
.to(Sink.ignore)
.run()
Now, I want to filter some of those messages
mapAsync.mapConcat
with Future[Option]
/Patrik
fre 13 jan. 2017 kl. 23:44 skrev jdenizac via Akka User List <
akka-user@googlegroups.com>:
> Hi! I'm somewhat new to akka-streams and trying to find the best way to
> express this flow:
>
> Let's say I have a stream of messages of type M for
>
> ca
