leakyabstraction

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

leakyabstraction

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._