Change the semantics of fornew()

Author: yruslan

src/main/scala/com/github/yruslan/channel/Channel.scala

@@ -67,8 +67,12 @@ abstract class Channel[T] extends ReadChannel[T] with WriteChannel[T] {
   }
 
   final override def fornew[U](f: T => U): Unit = {
-    val valueOpt = tryRecv()
-    valueOpt.foreach(v => f(v))
+    var valueOpt = tryRecv()
+
+    while (valueOpt.nonEmpty) {
+      valueOpt.foreach(v => f(v))
+      valueOpt = tryRecv()
+    }
   }
 
   final override def foreach[U](f: T => U): Unit = {

src/test/scala/com/github/yruslan/channel/ChannelFilterSuite.scala

@@ -166,18 +166,19 @@ class ChannelFilterSuite extends AnyWordSpec {
     }
 
     "filter input channel on fornew()" in {
-      val ch1 = Channel.make[Int](2)
+      val ch1 = Channel.make[Int](3)
 
       val ch2 = ch1.filter(v => v != 2)
 
       ch1.send(1)
       ch1.send(2)
+      ch1.send(3)
 
       var v1 = 0
 
       ch2.fornew(v => v1 = v)
 
-      assert(v1 == 1)
+      assert(v1 == 3)
     }
 
     "filter input channel on foreach()" in {

src/test/scala/com/github/yruslan/channel/ChannelSuite.scala

@@ -605,8 +605,10 @@ class ChannelSuite extends AnyWordSpec with BeforeAndAfterAll {
         ch.fornew(v => processed += v)
 
         assert(processed.nonEmpty)
-        assert(processed.size == 1)
+        assert(processed.size == 3)
         assert(processed.head == "test1")
+        assert(processed(1) == "test2")
+        assert(processed(2) == "test3")
       }
 
       "there are no data" in {
@@ -887,7 +889,8 @@ class ChannelSuite extends AnyWordSpec with BeforeAndAfterAll {
 
       assert(lst == List(2, 6))
     }
-
+  }
+  "for comprehension" should {
     "test for comprehension with yield" in {
       val ch1 = Channel.make[Int](3)