Making debug message formatting disabled when debug is disabled

Author: viktorklang

tck/src/main/java/org/reactivestreams/tck/IdentityProcessorVerification.java

@@ -504,7 +504,8 @@ public Subscriber<T> createSubscriber(final SubscriberWhiteboxVerification.White
 
           @Override
           public void onSubscribe(final Subscription subscription) {
-            env.debug(String.format("whiteboxSubscriber::onSubscribe(%s)", subscription));
+            if (env.debugEnabled())
+              env.debug(String.format("whiteboxSubscriber::onSubscribe(%s)", subscription));
             if (subs.isCompleted()) subscription.cancel(); // the Probe must also pass subscriber verification
 
             probe.registerOnSubscribe(new SubscriberWhiteboxVerification.SubscriberPuppet() {
@@ -523,19 +524,22 @@ public void signalCancel() {
 
           @Override
           public void onNext(T element) {
-            env.debug(String.format("whiteboxSubscriber::onNext(%s)", element));
+            if (env.debugEnabled())
+              env.debug(String.format("whiteboxSubscriber::onNext(%s)", element));
             probe.registerOnNext(element);
           }
 
           @Override
           public void onComplete() {
-            env.debug("whiteboxSubscriber::onComplete()");
+            if (env.debugEnabled())
+              env.debug("whiteboxSubscriber::onComplete()");
             probe.registerOnComplete();
           }
 
           @Override
           public void onError(Throwable cause) {
-            env.debug(String.format("whiteboxSubscriber::onError(%s)", cause));
+            if (env.debugEnabled())
+              env.debug(String.format("whiteboxSubscriber::onError(%s)", cause));
             probe.registerOnError(cause);
           }
         });

tck/src/main/java/org/reactivestreams/tck/PublisherVerification.java

@@ -772,7 +772,8 @@ public void onNext(T element) {
 
             signalsReceived += 1;
             stackDepthCounter.set(stackDepthCounter.get() + 1);
-            env.debug(String.format("%s(recursion depth: %d)::onNext(%s)", this, stackDepthCounter.get(), element));
+            if (env.debugEnabled())
+              env.debug(String.format("%s(recursion depth: %d)::onNext(%s)", this, stackDepthCounter.get(), element));
 
             final long callsUntilNow = stackDepthCounter.get();
             if (callsUntilNow > boundedDepthOfOnNextAndRequestRecursion()) {
@@ -1082,7 +1083,8 @@ public void required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue()
 
           @Override
           public void onNext(T element) {
-            env.debug(String.format("%s::onNext(%s)", this, element));
+            if (env.debugEnabled())
+              env.debug(String.format("%s::onNext(%s)", this, element));
             if (subscription.isCompleted()) {
               if (callsCounter > 0) {
                 subscription.value().request(Long.MAX_VALUE - 1);

tck/src/main/java/org/reactivestreams/tck/TestEnvironment.java

@@ -320,10 +320,14 @@ public void verifyNoAsyncErrorsNoDelay() {
 
   /** If {@code TestEnvironment#printlnDebug} is true, print debug message to std out. */
   public void debug(String msg) {
-    if (printlnDebug)
+    if (debugEnabled())
       System.out.printf("[TCK-DEBUG] %s%n", msg);
   }
 
+  public final boolean debugEnabled() {
+    return printlnDebug;
+  }
+
   /**
    * Looks for given {@code method} method in stack trace.
    * Can be used to answer questions like "was this method called from onComplete?".
@@ -578,7 +582,8 @@ public ManualSubscriberWithSubscriptionSupport(TestEnvironment env) {
 
     @Override
     public void onNext(T element) {
-      env.debug(String.format("%s::onNext(%s)", this, element));
+      if (env.debugEnabled())
+        env.debug(String.format("%s::onNext(%s)", this, element));
       if (subscription.isCompleted()) {
         super.onNext(element);
       } else {
@@ -588,7 +593,8 @@ public void onNext(T element) {
 
     @Override
     public void onComplete() {
-      env.debug(this + "::onComplete()");
+      if (env.debugEnabled())
+        env.debug(this + "::onComplete()");
       if (subscription.isCompleted()) {
         super.onComplete();
       } else {
@@ -598,7 +604,8 @@ public void onComplete() {
 
     @Override
     public void onSubscribe(Subscription s) {
-      env.debug(String.format("%s::onSubscribe(%s)", this, s));
+      if (env.debugEnabled())
+        env.debug(String.format("%s::onSubscribe(%s)", this, s));
       if (!subscription.isCompleted()) {
         subscription.complete(s);
       } else {
@@ -608,7 +615,8 @@ public void onSubscribe(Subscription s) {
 
     @Override
     public void onError(Throwable cause) {
-      env.debug(String.format("%s::onError(%s)", this, cause));
+      if (env.debugEnabled())
+        env.debug(String.format("%s::onError(%s)", this, cause));
       if (subscription.isCompleted()) {
         super.onError(cause);
       } else {
@@ -631,7 +639,8 @@ public BlackholeSubscriberWithSubscriptionSupport(TestEnvironment env) {
 
     @Override
     public void onNext(T element) {
-      env.debug(String.format("%s::onNext(%s)", this, element));
+      if (env.debugEnabled())
+        env.debug(String.format("%s::onNext(%s)", this, element));
       if (!subscription.isCompleted()) {
         env.flop(String.format("Subscriber::onNext(%s) called before Subscriber::onSubscribe", element));
       }