Reducing logging in reactivesocket unit tests

rwilliams-r7 · Jun 13, 2016 · d5c1203 · d5c1203
1 parent 2632c0e
commit d5c1203
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 9 deletions.
diff --git a/...c/test/java/com/netflix/hystrix/contrib/reactivesocket/EventStreamRequestHandlerTest.java b/...c/test/java/com/netflix/hystrix/contrib/reactivesocket/EventStreamRequestHandlerTest.java
@@ -79,9 +79,8 @@ public void onSubscribe(Subscription s) {
                 @Override
                 public void onNext(Payload payload) {
                     ByteBuffer data = payload.getData();
-                    String s = new String(data.array());
-
-                    System.out.println(s);
+                    //String s = new String(data.array());
+                    //System.out.println(s);
 
                     latch1.countDown();
                     latch2.countDown();
@@ -159,9 +158,8 @@ public void onSubscribe(Subscription s) {
             @Override
             public void onNext(Payload payload) {
                 ByteBuffer data = payload.getData();
-                String s = new String(data.array());
-
-                System.out.println(System.currentTimeMillis() + " : " + i.incrementAndGet());
+                //String s = new String(data.array());
+                //System.out.println(System.currentTimeMillis() + " : " + i.incrementAndGet());
 
                 latch1.countDown();
             }

diff --git a/.../src/test/java/com/netflix/hystrix/contrib/reactivesocket/HystrixDashboardStreamTest.java b/.../src/test/java/com/netflix/hystrix/contrib/reactivesocket/HystrixDashboardStreamTest.java
@@ -228,7 +228,6 @@ public void testTwoSubscribersOneSlowOneFast() throws Exception {
                 .observeOn(Schedulers.newThread())
                 .map(n -> {
                     try {
-                        System.out.println("Sleeping on thread : " + Thread.currentThread().getName());
                         Thread.sleep(100);
                         return n;
                     } catch (InterruptedException ex) {
@@ -257,7 +256,7 @@ public void onError(Throwable e) {
 
                     @Override
                     public void onNext(Boolean b) {
-                        System.out.println(System.currentTimeMillis() + " : " + Thread.currentThread().getName() + " : OnNext : " + b);
+                        //System.out.println(System.currentTimeMillis() + " : " + Thread.currentThread().getName() + " : OnNext : " + b);
                     }
                 });
 

diff --git a/...nt-stream/src/test/java/com/netflix/hystrix/contrib/reactivesocket/HystrixStreamTest.java b/...nt-stream/src/test/java/com/netflix/hystrix/contrib/reactivesocket/HystrixStreamTest.java
@@ -37,7 +37,6 @@ public SyntheticBlockingCommand() {
         @Override
         protected Integer run() throws Exception {
             int n = r.nextInt(100);
-            System.out.println(System.currentTimeMillis() + " : " + Thread.currentThread().getName() + " sleeping for : " + n);
             Thread.sleep(n);
             return n;
         }