Несоответствие типов при следовании примеру из документации в fs2

Question

Я пытаюсь создать приложение, используя FS2 (0.10.0). Я взял этот пример из документации:

import fs2._
// import fs2._

import fs2.async
// import fs2.async

import scala.concurrent.ExecutionContext
// import scala.concurrent.ExecutionContext

import cats.effect.{ Effect, IO }
// import cats.effect.{Effect, IO}

type Row = List[String]
// defined type alias Row

trait CSVHandle {
  def withRows(cb: Either[Throwable,Row] => Unit): Unit
}
// defined trait CSVHandle

def rows[F[_]](h: CSVHandle)(implicit F: Effect[F], ec: ExecutionContext): Stream[F,Row] =
  for {
    q <- Stream.eval(async.unboundedQueue[F,Either[Throwable,Row]])
    _ <- Stream.suspend { h.withRows { e => async.unsafeRunAsync(q.enqueue1(e))(_ => IO.unit) }; Stream.emit(()) }
    row <- q.dequeue.rethrow
  } yield row
// rows: [F[_]](h: CSVHandle)(implicit F: cats.effect.Effect[F], implicit ec: scala.concurrent.ExecutionContext)fs2.Stream[F,Row]

Но это не удается при компиляции с:

type mismatch;
[error]  found   : fs2.Stream[F,Row]
[error]  required: fs2.Stream[fs2.Pure,?]
[error] Expanded types:
[error] found   : fs2.Stream[F,List[String]]
[error] required: fs2.Stream[fs2.Pure,?]"
[error]       row <- q.dequeue.rethrow

Боюсь, я застрял и не понимаю, почему это происходит. Любая идея?

Answer 1

Согласно этому разговору Гиттера, в примере есть ошибка. Используйте вместо:

 def rows[F[_]](h: CSVHandle)(implicit F: Effect[F], ec: ExecutionContext): Stream[F,Row] =
   for {
     q <- Stream.eval(async.unboundedQueue[F,Either[Throwable,Row]])
     _ <-  Stream.eval { F.delay(h.withRows(e => async.unsafeRunAsync(q.enqueue1(e))(_ => IO.unit))) }
     row <- q.dequeue.rethrow
   } yield row