Skip to content

Instantly share code, notes, and snippets.

@duanebester
Created December 8, 2019 20:37
Show Gist options
  • Save duanebester/c2b067319d4b810daeac95218b46f7c0 to your computer and use it in GitHub Desktop.
Save duanebester/c2b067319d4b810daeac95218b46f7c0 to your computer and use it in GitHub Desktop.
Process Stage
def processStage(stageNum: Int) = Flow[BufferedImage]
.async
.delay(1 seconds)
.map(bi => {
println(s"Processing Stage: ${stageNum}")
bi
})
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment