Skip to content

Instantly share code, notes, and snippets.


Created May 31, 2017
What would you like to do?
the description for this gist
.mapAsync(1) {
case CommitableMsg(MsgA(a), offset) =>
someBusinessTask(a).map(_ => offset)
case CommitableMsg(_, offset) =>
.bufferTimedAndCounted(1.second, 100)
.mapAsync(1)(offsets => Task.fromFuture(offsets.last.commitOffset))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment