File tree 1 file changed +2
-4
lines changed
src/test/java/org/springframework/data/repository/util
1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change 20
20
import io .reactivex .Maybe ;
21
21
import kotlinx .coroutines .flow .Flow ;
22
22
import kotlinx .coroutines .flow .FlowKt ;
23
+ import kotlinx .coroutines .reactive .ReactiveFlowKt ;
23
24
import reactor .core .publisher .Flux ;
24
25
import reactor .core .publisher .Mono ;
25
26
import reactor .test .StepVerifier ;
26
27
import rx .Completable ;
27
28
import rx .Observable ;
28
29
import rx .Single ;
29
30
30
- import java .util .concurrent .atomic .AtomicBoolean ;
31
- import java .util .concurrent .atomic .AtomicReference ;
32
-
33
31
import org .junit .jupiter .api .Test ;
34
32
import org .reactivestreams .Publisher ;
35
33
@@ -323,6 +321,6 @@ void shouldMapKotlinFlow() {
323
321
324
322
Flow <String > flow = FlowKt .asFlow (new String [] { "foo" });
325
323
Flow <Long > map = ReactiveWrapperConverters .map (flow , source -> 1L );
326
- StepVerifier .create (kotlinx . coroutines . reactive . FlowKt .asPublisher (map )).expectNext (1L ).verifyComplete ();
324
+ StepVerifier .create (ReactiveFlowKt .asPublisher (map )).expectNext (1L ).verifyComplete ();
327
325
}
328
326
}
You can’t perform that action at this time.
0 commit comments