import monix.execution.cancelables.CompositeCancelable
import monix.execution.{Cancelable, Ack}
import monix.execution.Ack.{Stop, Continue}
import monix.reactive.Observable
import monix.reactive.observers.Subscriber
import scala.concurrent.{Promise, Future}
import scala.util.Success
import scala.util.control.NonFatal
An attempt to implement InterleaveObservable
in monix
with the similar behavior in scalaz-stream
/fs2
import monix.execution._
import monix.execution.cancelables._
import monix.execution.Ack._
import monix.reactive._
import monix.reactive.observers._
import scala.concurrent._