We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 46e0ed3 commit 295c620Copy full SHA for 295c620
src/main/scala/gallia/data/DataPackage.scala
@@ -14,6 +14,13 @@ package object data {
14
// ---------------------------------------------------------------------------
15
/** mostly for Iterator based processing */
16
trait DataRegenerationClosure[T] { def regenerate: () => aptus.CloseabledIterator[T] }
17
+
18
+ // ---------------------------------------------------------------------------
19
+ object DataRegenerationClosure {
20
+ def fromUncloseable[T](data: Iterator[T]) = new DataRegenerationClosure[T] {
21
+ def regenerate: () => aptus.CloseabledIterator[T] =
22
+ () => aptus.CloseabledIterator.fromUncloseable(data) } }
23
24
}
25
26
// ===========================================================================
0 commit comments