Scala ZIOStream с будущим

Question

я пытаюсь сочинять сZStream.asyncследуя этому примеру , но у меня есть проблема с типом:ZIO.fromFutureдает мнеTask[+A] = ZIO[Any, Throwable, A]ноZstream.emitпотребностиZIO[R, Option[E], Chunk[A]]

[

Как я могу превратить Future в ZStream, если это имеет смысл?

          val t: ZIO[Any, Throwable, Chunk[A]] = ZIO.fromFuture(_ => Future[A])
    val stream = ZStream.async[Any, Throwable, A] { cb =>
      cb(t)
      None
    }