Merge pull request #337 from seratch/patch-1

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

Author: viktorklang

CopyrightWaivers.txt

@@ -34,3 +34,4 @@ rstoyanchev    | Rossen Stoyanchev, [email protected], Pivotal
 BjornHamels    | Björn Hamels, [email protected]
 JakeWharton    | Jake Wharton, [email protected]
 anthonyvdotbe  | Anthony Vanelverdinghe, [email protected]
+seratch        | Kazuhiro Sera, [email protected], SmartNews, Inc.

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() {
       }
     }
   }
-}
+}