Update SourceSpec.scala

pjfanning · pjfanning · commit 9cc33eaeb28b · 2026-01-13T21:41:18.000+01:00
diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SourceSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SourceSpec.scala
@@ -713,7 +713,7 @@ class SourceSpec extends StreamSpec with DefaultTimeout {
         Await.result(source.runWith(Sink.ignore), Duration.Inf)
       }
 
-      assert(counter.get() == 3)
+      assert(counter.get() == 1)
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -713,7 +713,7 @@ class SourceSpec extends StreamSpec with DefaultTimeout {`
`713`	`713`	`Await.result(source.runWith(Sink.ignore), Duration.Inf)`
`714`	`714`	`}`
`715`	`715`
`716`		`- assert(counter.get() == 3)`
	`716`	`+ assert(counter.get() == 1)`
`717`	`717`	`}`
`718`	`718`	`}`
`719`	`719`