spring-projects#297 - Adapt to latest API changes in RxJava 2 in Cass…

…andra module.
wfm0105 · Oct 6, 2017 · ffc33fc · ffc33fc
1 parent 562b959
commit ffc33fc
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...test/java/example/springdata/cassandra/people/RxJava2PersonRepositoryIntegrationTest.java b/...test/java/example/springdata/cassandra/people/RxJava2PersonRepositoryIntegrationTest.java
@@ -55,7 +55,7 @@ public void setUp() throws Exception {
 
 		Completable deleteAll = repository.deleteAll();
 
-		Observable<Person> save = repository.saveAll(Observable.just(new Person("Walter", "White", 50), //
+		Flowable<Person> 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 void shouldInsertAndCountData() throws Exception {
 
 		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() //