io.monix:monix-reactive_2.11

Enables asynchronous processing of data streams.