Skip to content

Instantly share code, notes, and snippets.

/post.scala

Created Jun 29, 2017
Embed
What would you like to do?
the description for this gist
implicit val s: Scheduler = ???
val messages: Observable[OutboundMessage] = ???
val exchangeConsumer: Consumer[OutboundMessage, Unit] = ???
val produce: Task[Unit] = exchangeConsumer(messages)
val production: Cancelable = produce.runAsync
production.cancel()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.