Skip to content

Instantly share code, notes, and snippets.

@duanebester
Created December 9, 2019 00:07
Show Gist options
  • Save duanebester/7fb3e8c02686ef3b628e9786f0b52211 to your computer and use it in GitHub Desktop.
Save duanebester/7fb3e8c02686ef3b628e9786f0b52211 to your computer and use it in GitHub Desktop.
Process Image Flow
def processImageFlow(): Flow[BufferedImage, ImageProcessed, NotUsed] =
processStage(1)
.via(processStage(2))
.via(processStage(3))
.via(processStage(4))
.map(_ => ImageProcessed("Complete!"))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment