File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
src/test/java/org/springframework/data/repository/util Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change 2020import io .reactivex .Maybe ;
2121import kotlinx .coroutines .flow .Flow ;
2222import kotlinx .coroutines .flow .FlowKt ;
23+ import kotlinx .coroutines .reactive .ReactiveFlowKt ;
2324import reactor .core .publisher .Flux ;
2425import reactor .core .publisher .Mono ;
2526import reactor .test .StepVerifier ;
2627import rx .Completable ;
2728import rx .Observable ;
2829import rx .Single ;
2930
30- import java .util .concurrent .atomic .AtomicBoolean ;
31- import java .util .concurrent .atomic .AtomicReference ;
32-
3331import org .junit .jupiter .api .Test ;
3432import org .reactivestreams .Publisher ;
3533
@@ -323,6 +321,6 @@ void shouldMapKotlinFlow() {
323321
324322 Flow <String > flow = FlowKt .asFlow (new String [] { "foo" });
325323 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 ();
327325 }
328326}
You can’t perform that action at this time.
0 commit comments