#803 - stream

typelevel · Mar 21, 2024 · e157cdb · e157cdb
1 parent 08d7c3d
commit e157cdb
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/dataset/src/main/scala/frameless/TypedEncoder.scala b/dataset/src/main/scala/frameless/TypedEncoder.scala
@@ -511,7 +511,13 @@ object TypedEncoder {
   object CollectionConversion {
 
     implicit def seqToSeq[Y] = new CollectionConversion[Seq, Seq, Y] {
-      override def convert(c: Seq[Y]): Seq[Y] = c
+
+      override def convert(c: Seq[Y]): Seq[Y] =
+        c match {
+          // Stream is produced
+          case _: Stream[Y] @unchecked => c.toVector.toSeq
+          case _                       => c
+        }
     }
 
     implicit def seqToVector[Y] = new CollectionConversion[Seq, Vector, Y] {