Come convertire Iterator in flusso scalaz?

Question

Supponiamo di avere un Iterator[A]. Vorrei convertirlo in Process[Nothing, A] di scalaz stream.

import scalaz.stream._ 

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

Come implementare foo?

Answer 1

penso che si può fare usando 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 
} 

Esempio:

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