Collect all kinds of akka programming exceptions and fault solutions.

Akka Stream Materialized Value

I want to reference the materialized value from the flow. Below is the code snippet, but its not compiling, error:
type mismatch;
found : (akka.NotUsed, scala.concurrent.Future[akka.Done])

CQRS command validation that requires a DB call

In CQRS, What is the best way to validate commands that require DB call?
For example, I have Order aggregate that is validating a command say CommitOrder and I don't want to accept this command unl...