This is an automated email from the ASF dual-hosted git repository.
reta pushed a commit to branch 3.2.x-fixes
in repository https://gitbox.apache.org/repos/asf/cxf.git
The following commit(s) were added to refs/heads/3.2.x-fixes by this push:
new 32e45e5 CXF-8357: RxJava2/RxJava3: Add support of Maybe type. Fixed
test cases (different semantics of hasEntity() method)
32e45e5 is described below
commit 32e45e5a1c4a82845ef546e437c08aa2e5858c10
Author: reta <[email protected]>
AuthorDate: Sat Nov 28 18:11:47 2020 -0500
CXF-8357: RxJava2/RxJava3: Add support of Maybe type. Fixed test cases
(different semantics of hasEntity() method)
(cherry picked from commit f2cccf2f2a8b2d0cd914c2adb9ac7959fb6430b2)
---
.../org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava2MaybeTest.java | 2 +-
.../org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava3MaybeTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava2MaybeTest.java
b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava2MaybeTest.java
index f4f351e..c0545c3 100644
---
a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava2MaybeTest.java
+++
b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava2MaybeTest.java
@@ -130,7 +130,7 @@ public class JAXRSRxJava2MaybeTest extends
AbstractBusClientServerTestBase {
subscriber.await(3, TimeUnit.SECONDS);
subscriber
- .assertValue(r -> !r.hasEntity())
+ .assertValue(r -> "".equals(r.readEntity(String.class)))
.assertComplete();
}
}
diff --git
a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava3MaybeTest.java
b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava3MaybeTest.java
index 1c4c95e..1d24a74 100644
---
a/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava3MaybeTest.java
+++
b/systests/jaxrs/src/test/java/org/apache/cxf/systest/jaxrs/reactive/JAXRSRxJava3MaybeTest.java
@@ -130,7 +130,7 @@ public class JAXRSRxJava3MaybeTest extends
AbstractBusClientServerTestBase {
subscriber.await(3, TimeUnit.SECONDS);
subscriber
- .assertValue(r -> !r.hasEntity())
+ .assertValue(r -> "".equals(r.readEntity(String.class)))
.assertComplete();
}
}