raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Fix LazySourceSpec instability

Browse source 
Don't make claims about whether this stage has completed.

Fixes #30492
This commit is contained in:
Arnout Engelen 2021-08-13 14:40:43 +00:00
parent 999b0853d5
commit 4cf66549be
No known key found for this signature in database
GPG key ID: 061107B0F74A6DAA
1 changed files with 2 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream-tests/src/test/scala/akka/stream/scaladsl/LazySourceSpec.scala
View file

@ -124,7 +124,7 @@ class LazySourceSpec extends StreamSpec with DefaultTimeout with ScalaFutures {
"never construct the source when there was no demand" in assertAllStagesStopped { "never construct the source when there was no demand" in assertAllStagesStopped {
val constructed = new AtomicBoolean(false) val constructed = new AtomicBoolean(false)
val result = Source Source
.lazySource { () => .lazySource { () =>
constructed.set(true); Source(List(1, 2, 3)) constructed.set(true); Source(List(1, 2, 3))
} }
@ -132,7 +132,6 @@ class LazySourceSpec extends StreamSpec with DefaultTimeout with ScalaFutures {
.run() .run()
constructed.get() should ===(false) constructed.get() should ===(false)
result.isCompleted should ===(false)
} }
"fail the materialized value when downstream cancels without ever consuming any element" in assertAllStagesStopped { "fail the materialized value when downstream cancels without ever consuming any element" in assertAllStagesStopped {
@ -271,7 +270,7 @@ class LazySourceSpec extends StreamSpec with DefaultTimeout with ScalaFutures {
"never construct the source when there was no demand" in assertAllStagesStopped { "never construct the source when there was no demand" in assertAllStagesStopped {
val constructed = new AtomicBoolean(false) val constructed = new AtomicBoolean(false)
val result = Source Source
.lazyFutureSource { () => .lazyFutureSource { () =>
Future { Future {
constructed.set(true) constructed.set(true)
@ -282,7 +281,6 @@ class LazySourceSpec extends StreamSpec with DefaultTimeout with ScalaFutures {
.run() .run()
constructed.get() should ===(false) constructed.get() should ===(false)
result.isCompleted should ===(false)
} }
"fail the materialized value when downstream cancels without ever consuming any element" in assertAllStagesStopped { "fail the materialized value when downstream cancels without ever consuming any element" in assertAllStagesStopped {