Skip to content

Instantly share code, notes, and snippets.

Created Jun 29, 2017
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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment