From 587d402d2ffe64f04ba43f9d91c345e310fc62d1 Mon Sep 17 00:00:00 2001 From: Daniel Vigovszky Date: Sun, 6 Feb 2022 10:35:46 +0100 Subject: [PATCH] Fix --- .../io/github/vigoo/prox/tests/zstream/ProcessGroupSpecs.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/prox-zstream-2/src/test/scala/io/github/vigoo/prox/tests/zstream/ProcessGroupSpecs.scala b/prox-zstream-2/src/test/scala/io/github/vigoo/prox/tests/zstream/ProcessGroupSpecs.scala index 54d9ad9c..a54a5d3f 100644 --- a/prox-zstream-2/src/test/scala/io/github/vigoo/prox/tests/zstream/ProcessGroupSpecs.scala +++ b/prox-zstream-2/src/test/scala/io/github/vigoo/prox/tests/zstream/ProcessGroupSpecs.scala @@ -339,7 +339,7 @@ object ProcessGroupSpecs extends DefaultRunnableSpec with ProxSpecHelpers { val processGroup = (p1 | p2).customizedPerProcess.foldErrors( { case p if p == p1 => ZPipeline.utf8Decode >>> ZPipeline.splitLines - case p if p == p2 => ZPipeline.utf8Decode >>> ZPipeline.splitLines >>> ZPipeline.map(_.reverse) + case p if p == p2 => ZPipeline.utf8Decode >>> ZPipeline.splitLines >>> ZPipeline.map[String, String](_.reverse) }, Vector.empty, (l: Vector[Option[Char]], s: String) => l :+ s.headOption