Spring/spring-data-mongodb
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATAMONGO-2558 - Polishing.

Browse Source 
Fixed issue number in tests.

Original pull request: #866.
This commit is contained in:
Mark Paluch
2020-05-26 08:39:58 +02:00
committed by Jens Schauder
parent da7fc927fa
commit a27939808b
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-data-mongodb/src/test/java/org/springframework/data/mongodb/repository/ConvertingReactiveMongoRepositoryTests.java
View File

@@ -244,7 +244,7 @@ public class ConvertingReactiveMongoRepositoryTests {
testObserver.assertValue(boyd);
}
@Test // DATAMONGO-1610
@Test // DATAMONGO-2558
public void simpleRxJava3MethodsShouldWork() {
TestObserver<Boolean> testObserver = rxJava3PersonRepostitory.existsById(dave.getId()).test();
@@ -255,7 +255,7 @@ public class ConvertingReactiveMongoRepositoryTests {
testObserver.assertValue(true);
}
@Test // DATAMONGO-1610
@Test // DATAMONGO-2558
public void existsWithSingleRxJava3IdMethodsShouldWork() {
TestObserver<Boolean> testObserver = rxJava3PersonRepostitory.existsById(io.reactivex.Single.just(dave.getId()))
@@ -267,7 +267,7 @@ public class ConvertingReactiveMongoRepositoryTests {
testObserver.assertValue(true);
}
@Test // DATAMONGO-1610
@Test // DATAMONGO-2558
public void flowableRxJava3QueryMethodShouldWork() throws InterruptedException {
TestSubscriber<ReactivePerson> testSubscriber = rxJava3PersonRepostitory
@@ -279,7 +279,7 @@ public class ConvertingReactiveMongoRepositoryTests {
testSubscriber.assertValue(dave);
}
@Test // DATAMONGO-1610
@Test // DATAMONGO-2558
public void singleProjectedRxJava3QueryMethodShouldWork() throws InterruptedException {
io.reactivex.rxjava3.observers.TestObserver<ProjectedPerson> testObserver = rxJava3PersonRepostitory
@@ -295,7 +295,7 @@ public class ConvertingReactiveMongoRepositoryTests {
});
}
@Test // DATAMONGO-1610
@Test // DATAMONGO-2558
public void observableProjectedRxJava3QueryMethodShouldWork() throws InterruptedException {
io.reactivex.rxjava3.observers.TestObserver<ProjectedPerson> testObserver = rxJava3PersonRepostitory
@@ -311,7 +311,7 @@ public class ConvertingReactiveMongoRepositoryTests {
});
}
@Test // DATAMONGO-1610
@Test // DATAMONGO-2558
public void maybeRxJava3QueryMethodShouldWork() throws InterruptedException {
io.reactivex.rxjava3.observers.TestObserver<ReactivePerson> testObserver = rxJava3PersonRepostitory