Leak example for Observable#firstL

LeakSample.scala

import monix.execution.Scheduler
import monix.reactive.Observable

object LeakSample {
  def main(args: Array[String]) {
    implicit val scheduler = Scheduler.computation(2)

    val hotObservable = (1 +: Observable.never).behavior(0)
    hotObservable.connect()

    val task = hotObservable.firstL

    while (true) task.runAsync(_ => {})
  }
}