Skip to content

Commit 8b23a2e

Browse files
authored
Fix a typo in org.reactivestreams.example.unicast.AsyncSubscriber
1 parent 4e8e372 commit 8b23a2e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

examples/src/main/java/org/reactivestreams/example/unicast/AsyncSubscriber.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ else if (s instanceof OnSubscribe)
199199
handleOnSubscribe(((OnSubscribe)s).subscription);
200200
else if (s instanceof OnError) // We are always able to handle OnError, obeying rule 2.10
201201
handleOnError(((OnError)s).error);
202-
else if (s == OnComplete.Instance) // We are always able to handle OnError, obeying rule 2.9
202+
else if (s == OnComplete.Instance) // We are always able to handle OnComplete, obeying rule 2.9
203203
handleOnComplete();
204204
}
205205
} finally {
@@ -235,4 +235,4 @@ private final void tryScheduleToExecute() {
235235
}
236236
}
237237
}
238-
}
238+
}

0 commit comments

Comments
 (0)