recurse

recurse.scala

object Test {
  type Paged[A] = Single[(A, Option[Single[_]])]
  val s: Paged[Int]= Single((1, Some(Single((2, None)))))
  def recurse[A](paged: Paged[A]): Observable[A] = paged
    .toObservable
    .flatMap {
      case (i, None) => Observable(i)
      case (i, Some(page: Paged[A])) => Observable.pure(i) ++ recurse(page)
    }
  def main(args: Array[String]): Unit = {
  recurse(s).foreach(println)
  }
}