diff --git a/examples/src/main/java/org/reactivestreams/example/unicast/AsyncSubscriber.java b/examples/src/main/java/org/reactivestreams/example/unicast/AsyncSubscriber.java index 35e85547..94c84cc5 100644 --- 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() { } } } -} \ No newline at end of file +}