Skip to content

Instantly share code, notes, and snippets.

@rocketpages

rocketpages/DroppyStream.scala

Created August 23, 2015 21:06
Show Gist options
  • Save rocketpages/cba443bdd743d33e255e to your computer and use it in GitHub Desktop.
Save rocketpages/cba443bdd743d33e255e to your computer and use it in GitHub Desktop.
Download ZIP
Raw
DroppyStream.scala
// return the freshest element when there's capacity downstream, drop everything else
val droppyStream: Flow[Message, Message] =
Flow[Message].conflate(seed = identity)((lastMessage, newMessage) => newMessage)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment