Skip to content

Instantly share code, notes, and snippets.

@joshcough
Last active August 29, 2015 14:26
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save joshcough/4f6958336a4df49cadfa to your computer and use it in GitHub Desktop.
Save joshcough/4f6958336a4df49cadfa to your computer and use it in GitHub Desktop.
Process(words:_*).
observe(printer).
through(kinesisChan). // this has to be fast, and i dont care about the rest
through(runFutures). // so all this stuff can be slow
map(_.toString).
observe(printer).
run.run
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment