You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by nf...@apache.org on 2017/04/27 13:39:13 UTC
camel git commit: Fix logs on stderr during tests
Repository: camel
Updated Branches:
refs/heads/master 63b3caf04 -> 2be04c739
Fix logs on stderr during tests
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2be04c73
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2be04c73
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2be04c73
Branch: refs/heads/master
Commit: 2be04c739dd0c5a40259cf90b50eed6502d362d4
Parents: 63b3caf
Author: Nicola Ferraro <ni...@gmail.com>
Authored: Thu Apr 27 15:38:28 2017 +0200
Committer: Nicola Ferraro <ni...@gmail.com>
Committed: Thu Apr 27 15:38:38 2017 +0200
----------------------------------------------------------------------
.../streams/DelayedMonoPublisherTest.java | 24 ++++++++++++--------
1 file changed, 15 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/2be04c73/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java
----------------------------------------------------------------------
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java
index 9361473..18814e8 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java
@@ -84,9 +84,11 @@ public class DelayedMonoPublisherTest {
CountDownLatch latch = new CountDownLatch(1);
Flowable.fromPublisher(pub)
- .doOnError(exceptions::add)
- .doOnError(e -> latch.countDown())
- .subscribe();
+ .subscribe(item -> {
+ }, e -> {
+ exceptions.add(e);
+ latch.countDown();
+ });
assertTrue(latch.await(1, TimeUnit.SECONDS));
@@ -207,17 +209,21 @@ public class DelayedMonoPublisherTest {
CountDownLatch latch = new CountDownLatch(2);
Flowable.fromPublisher(pub)
- .doOnError(exceptions::add)
- .doOnError(e -> latch.countDown())
- .subscribe();
+ .subscribe(item -> {
+ }, e -> {
+ exceptions.add(e);
+ latch.countDown();
+ });
Thread.sleep(200);
pub.setException(ex);
Flowable.fromPublisher(pub)
- .doOnError(exceptions::add)
- .doOnError(e -> latch.countDown())
- .subscribe();
+ .subscribe(item -> {
+ }, e -> {
+ exceptions.add(e);
+ latch.countDown();
+ });
assertTrue(latch.await(1, TimeUnit.SECONDS));