diff --git a/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/ReactiveMongoTemplateExecuteTests.java b/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/ReactiveMongoTemplateExecuteTests.java index aae70605b..aea113e1c 100644 --- a/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/ReactiveMongoTemplateExecuteTests.java +++ b/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/ReactiveMongoTemplateExecuteTests.java @@ -15,7 +15,6 @@ */ package org.springframework.data.mongodb.core; -import static com.sun.prism.impl.Disposer.*; import static org.hamcrest.Matchers.*; import static org.junit.Assert.*; import static org.junit.Assume.*; @@ -24,7 +23,6 @@ import reactor.core.publisher.Flux; import reactor.test.StepVerifier; import org.bson.Document; -import org.junit.After; import org.junit.Before; import org.junit.Rule; import org.junit.Test; @@ -62,7 +60,13 @@ public class ReactiveMongoTemplateExecuteTests { @Before public void setUp() { - cleanUp(); + + Flux cleanup = operations.dropCollection("person") // + .mergeWith(operations.dropCollection("execute_test")) // + .mergeWith(operations.dropCollection("execute_test1")) // + .mergeWith(operations.dropCollection("execute_test2")); + + StepVerifier.create(cleanup).verifyComplete(); if (mongoVersion == null) { mongoVersion = operations.executeCommand("{ buildInfo: 1 }") // @@ -72,19 +76,6 @@ public class ReactiveMongoTemplateExecuteTests { } } - @After - public void tearDown() { - - Flux cleanup = operations.dropCollection("person") // - .mergeWith(operations.dropCollection(Person.class)) // - .mergeWith(operations.dropCollection("execute_test")) // - .mergeWith(operations.dropCollection("execute_test1")) // - .mergeWith(operations.dropCollection("execute_test2")) // - .mergeWith(operations.dropCollection("execute_index_test")); - - StepVerifier.create(cleanup).verifyComplete(); - } - @Test // DATAMONGO-1444 public void executeCommandJsonCommandShouldReturnSingleResponse() {