Add forEach test

scala-native · Oct 10, 2023 · e1a5d5c · e1a5d5c
1 parent adddeb8
commit e1a5d5c
Showing 1 changed file with 13 additions and 4 deletions.
diff --git a/...est/scala/org/scalanative/testsuite/javalib/util/concurrent/LinkedTransferQueueTest.scala b/...est/scala/org/scalanative/testsuite/javalib/util/concurrent/LinkedTransferQueueTest.scala
@@ -18,7 +18,6 @@ import java.util.concurrent._
 import java.util.concurrent.LinkedTransferQueue
 import scala.collection.mutable.ArrayBuffer
 import scala.util.Using
-import scala.compiletime.ops.boolean
 
 class LinkedTransferQueueTest extends JSR166Test {
   @Test def testConstructor1() = {
@@ -343,7 +342,7 @@ class LinkedTransferQueueTest extends JSR166Test {
   /** An add following remove(x) succeeds
    */
   @Test def testRemoveElementAndAdd() = {
-    val q = LinkedTransferQueue[Item]()
+    val q = new LinkedTransferQueue[Item]()
     mustAdd(q, one)
     mustAdd(q, two)
     mustRemove(q, one)
@@ -698,8 +697,7 @@ class LinkedTransferQueueTest extends JSR166Test {
     threadStarted.await()
     val oneConsumer = new Callable[Boolean]() {
       override def call() =
-        q.hasWaitingConsumer()
-          && q.getWaitingConsumerCount() == 1
+        q.hasWaitingConsumer() && q.getWaitingConsumerCount() == 1
 
     }
     waitForThreadToEnterWaitState(t, oneConsumer)
@@ -1015,6 +1013,17 @@ class LinkedTransferQueueTest extends JSR166Test {
       assertFalse(q.remove(null));
     }
   }
+
+  /* ==== Not from JSR166 ==== */
+  @Test def testForEach() = {
+    val q = new LinkedTransferQueue[Item]()
+    q.add(itemFor(one))
+    q.add(itemFor(two))
+
+    q.forEach { x =>
+      assertTrue(x == itemFor(one) || x == itemFor(two))
+    }
+  }
 }
 
 object LinkedTransferQueueTest {