From 3dcea0296a340da356934ea1afcdf0746af82a7a Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Mon, 12 Jul 2021 15:26:18 +0200 Subject: [PATCH] Adopt to changes in Kotlin Coroutines 1.5.1. Closes #2411 --- .../repository/util/ReactiveWrapperConvertersUnitTests.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/test/java/org/springframework/data/repository/util/ReactiveWrapperConvertersUnitTests.java b/src/test/java/org/springframework/data/repository/util/ReactiveWrapperConvertersUnitTests.java index 16ce5cb6e..b196901d0 100644 --- a/src/test/java/org/springframework/data/repository/util/ReactiveWrapperConvertersUnitTests.java +++ b/src/test/java/org/springframework/data/repository/util/ReactiveWrapperConvertersUnitTests.java @@ -20,6 +20,7 @@ import static org.assertj.core.api.AssertionsForClassTypes.*; import io.reactivex.Maybe; import kotlinx.coroutines.flow.Flow; import kotlinx.coroutines.flow.FlowKt; +import kotlinx.coroutines.reactive.ReactiveFlowKt; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import reactor.test.StepVerifier; @@ -27,9 +28,6 @@ import rx.Completable; import rx.Observable; import rx.Single; -import java.util.concurrent.atomic.AtomicBoolean; -import java.util.concurrent.atomic.AtomicReference; - import org.junit.jupiter.api.Test; import org.reactivestreams.Publisher; @@ -323,6 +321,6 @@ class ReactiveWrapperConvertersUnitTests { Flow flow = FlowKt.asFlow(new String[] { "foo" }); Flow map = ReactiveWrapperConverters.map(flow, source -> 1L); - StepVerifier.create(kotlinx.coroutines.reactive.FlowKt.asPublisher(map)).expectNext(1L).verifyComplete(); + StepVerifier.create(ReactiveFlowKt.asPublisher(map)).expectNext(1L).verifyComplete(); } }