From ffc33fcf9293418212abfd13979e7139c9f5b6c4 Mon Sep 17 00:00:00 2001 From: Oliver Gierke Date: Fri, 6 Oct 2017 18:24:58 +0200 Subject: [PATCH] #297 - Adapt to latest API changes in RxJava 2 in Cassandra module. --- .../people/RxJava2PersonRepositoryIntegrationTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cassandra/reactive/src/test/java/example/springdata/cassandra/people/RxJava2PersonRepositoryIntegrationTest.java b/cassandra/reactive/src/test/java/example/springdata/cassandra/people/RxJava2PersonRepositoryIntegrationTest.java index 1a07283f..612f09ec 100644 --- a/cassandra/reactive/src/test/java/example/springdata/cassandra/people/RxJava2PersonRepositoryIntegrationTest.java +++ b/cassandra/reactive/src/test/java/example/springdata/cassandra/people/RxJava2PersonRepositoryIntegrationTest.java @@ -55,7 +55,7 @@ public class RxJava2PersonRepositoryIntegrationTest { Completable deleteAll = repository.deleteAll(); - Observable save = repository.saveAll(Observable.just(new Person("Walter", "White", 50), // + Flowable save = repository.saveAll(Flowable.just(new Person("Walter", "White", 50), // new Person("Skyler", "White", 45), // new Person("Saul", "Goodman", 42), // new Person("Jesse", "Pinkman", 27))); @@ -73,8 +73,8 @@ public class RxJava2PersonRepositoryIntegrationTest { repository.count() // .doOnSuccess(System.out::println) // - .toObservable() // - .switchMap(count -> repository.saveAll(Observable.just(new Person("Hank", "Schrader", 43), // + .toFlowable() // + .switchMap(count -> repository.saveAll(Flowable.just(new Person("Hank", "Schrader", 43), // new Person("Mike", "Ehrmantraut", 62)))) // .lastElement() // .toSingle() //