Fix a typo in org.reactivestreams.example.unicast.AsyncSubscriber

reactive-streams · Jan 3, 2017 · 8b23a2e · 8b23a2e
1 parent 4e8e372
commit 8b23a2e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/examples/src/main/java/org/reactivestreams/example/unicast/AsyncSubscriber.java b/examples/src/main/java/org/reactivestreams/example/unicast/AsyncSubscriber.java
@@ -199,7 +199,7 @@ else if (s instanceof OnSubscribe)
             handleOnSubscribe(((OnSubscribe)s).subscription);
           else if (s instanceof OnError) // We are always able to handle OnError, obeying rule 2.10
             handleOnError(((OnError)s).error);
-          else if (s == OnComplete.Instance) // We are always able to handle OnError, obeying rule 2.9
+          else if (s == OnComplete.Instance) // We are always able to handle OnComplete, obeying rule 2.9
             handleOnComplete();
         }
       } finally {
@@ -235,4 +235,4 @@ private final void tryScheduleToExecute() {
       }
     }
   }
-}
+}