Re: [akka-user] Abstracting away CommitableMessage

Broadcast/Zip if your existing flow is 1:1. Here's a sample: https://github.com/iravid/stream-processing-talk/blob/master/GraphDSL.scala#L86 -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html

Re: [akka-user] [akka-streams] Wrapping one flow with another while keeping the inner's materialized value

Mat] > > (click to expand to see the ASCII-art diagram of how it works). > > -Endre > > On Fri, Aug 19, 2016 at 6:09 PM, Itamar Ravid <ira...@iravid.com > > wrote: > >> Hi everyone, >> >> >> I'm trying to write a function that wraps an arbitrary

[akka-user] [akka-streams] Wrapping one flow with another while keeping the inner's materialized value

Hi everyone, I'm trying to write a function that wraps an arbitrary flow with another flow that performs a side-effect: measures the execution time of the inner flow. I'm also trying to avoid writing a custom GraphStage to do this. So far, I've come up with this: def measuredFlow[In,

Re: [akka-user] [akka-streams] Accessing the dispatcher used for a mapAsync stage

Thanks Endre! -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are

[akka-user] [akka-streams] Accessing the dispatcher used for a mapAsync stage

Hello everyone, Is there a canonical way of accessing the dispatcher/ExecutionContext used for a mapAsync stage? I would like to use the monadic combinators on a future within my mapAsync stage, and these require an implicit ExecutionContext. Contrived example: ``` def myFlow =

[akka-user] Akka, log4j2 and structured log messages

Hi, has anyone by chance implemented (and would like to share :-)) an akka.event.LoggingAdapter implementation with support for log4j2's structured log messages? Thanks, Itamar -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>