camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nferr...@apache.org
Subject camel git commit: Fix logs on stderr during tests
Date Thu, 27 Apr 2017 13:39:13 GMT
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.ferraro@gmail.com>
Authored: Thu Apr 27 15:38:28 2017 +0200
Committer: Nicola Ferraro <ni.ferraro@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));
 


Mime
View raw message