Skip to content

Commit 8cb8095

Browse files
authored
Add forFew to Queue test to unveil some race problems then fixed with a tiny sleep (#122)
1 parent 0563808 commit 8cb8095

File tree

2 files changed

+192
-153
lines changed

2 files changed

+192
-153
lines changed

arrow-libs/fx/arrow-fx-test/src/main/kotlin/arrow/fx/test/laws/ConcurrentLaws.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,7 @@ object ConcurrentLaws {
279279
fun <F> Concurrent<F>.cancellableReceivesCancelSignal(EQ: Eq<Kind<F, Int>>, ctx: CoroutineContext) =
280280
forAll(Gen.int()) { i ->
281281
fx.concurrent {
282-
val release = Promise.uncancellable<F, Int>(this@cancellableReceivesCancelSignal).bind()
282+
val release = Promise<F, Int>(this@cancellableReceivesCancelSignal).bind()
283283
val latch = UnsafePromise<Unit>()
284284

285285
val (_, cancel) = cancellable<Unit> {

0 commit comments

Comments
 (0)