spring-projects#297 - Adapt to latest API changes in Reactor 3.1 RC1 and Spring Data MongoDB.

Author: odrotbohm

cassandra/reactive/src/test/java/example/springdata/cassandra/people/ReactiveCassandraTemplateIntegrationTest.java

@@ -79,7 +79,7 @@ public void shouldInsertAndCountData() throws Exception {
 				.last() //
 				.flatMap(v -> template.count(Person.class)) //
 				.doOnNext(System.out::println) //
-				.doOnTerminate((i, t) -> countDownLatch.countDown()) //
+				.doOnTerminate(countDownLatch::countDown) //
 				.subscribe();
 
 		countDownLatch.await();

cassandra/reactive/src/test/java/example/springdata/cassandra/people/ReactivePersonRepositoryIntegrationTest.java

@@ -75,7 +75,7 @@ public void shouldInsertAndCountData() throws Exception {
 				.last() //
 				.flatMap(v -> repository.count()) //
 				.doOnNext(System.out::println) //
-				.doOnTerminate((l, t) -> countDownLatch.countDown()) //
+				.doOnTerminate(countDownLatch::countDown) //
 				.subscribe();
 
 		countDownLatch.await();

mongodb/reactive/src/main/java/example/springdata/mongodb/people/ApplicationConfiguration.java

@@ -54,7 +54,7 @@ public LoggingEventListener mongoEventListener() {
 	@Override
 	@Bean
 	@DependsOn("embeddedMongoServer")
-	public MongoClient mongoClient() {
+	public MongoClient reactiveMongoClient() {
 		int port = environment.getProperty("local.mongo.port", Integer.class);
 		return MongoClients.create(String.format("mongodb://localhost:%d", port));
 	}