Skip to content

Instantly share code, notes, and snippets.


Created May 31, 2017
What would you like to do?
the description for this gist
// ActorSystem and ActorMaterializer available in implicit scope
.mapAsync(1) {
case CommitableMsg(MsgA(a), offset) =>
someBusinessFuture(a).map(_ => offset)
case CommitableMsg(_, offset) =>
.groupedWithin(100, 1.seconds)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment