Skip to content

Instantly share code, notes, and snippets.

@gardnervickers

gardnervickers/gist:9e915efc3ec875c68bcd

Last active August 29, 2015 14:21
Show Gist options
  • Save gardnervickers/9e915efc3ec875c68bcd to your computer and use it in GitHub Desktop.
Save gardnervickers/9e915efc3ec875c68bcd to your computer and use it in GitHub Desktop.
Download ZIP
flow-combine in onyx
Raw
gistfile1.clj
Executing before task -=___ Peer 1 starts task/job and batch
Executing before batch -=__/ Segments are loaded through the :core.async/read-from-chan :in
Executing after batch -=__/
Executing before batch -=___ Segments are loaded into the :inc function and processed
Executing after batch -=__/
Executing before batch -=___ Segments are loaded through the :core.async/write-to-chan :out
Executing after task -=___ Why does this happen *before* "Executing after batch"
Executing after batch -=__/
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment