Как преобразовать Iterator в поток scalaz?

Question

Предположим, у меня есть Iterator[A]. Я хотел бы преобразовать его в Process[Nothing, A] из scalaz stream.

import scalaz.stream._ 

def foo[A](it: Iterator[A]): Process[Nothing, A] = ??? 

Как вы бы описали foo?

Answer 1

Я думаю, что вы можете сделать это с помощью unfold:

import scalaz.stream._ 

def foo[A](it: Iterator[A]): Process[Nothing, A] = Process.unfold(it) { it => 
    if (it.hasNext) Some((it.next, it)) 
    else None 
} 

Пример:

scala> foo(List(1,2,3,4,5).iterator).toList 
res0: List[Int] = List(1,2,3,4,5)