Attempt at making a streamwrapper that buffers the next result

gistfile1.scala

  def prefetch[A](slowSource: Stream[A]): Stream[A] = {
    def fetch(stream: => Stream[A]) = {
      Future {
        stream(1)
      }
    }
    def cons(head: Future[A], tail: => Stream[A]): Stream[A] = {
      val next = fetch(tail)
      Await.result(head, Duration.Inf) #:: cons(next, tail.tail)
    }
    
    slowSource.head #:: cons(fetch(slowSource.tail), slowSource.tail.tail)
  }