examples: Fix typo in comments (#6721)

This commit is contained in:
Ziad Hatahet 2020-02-18 13:16:08 -05:00 committed by GitHub
parent 161a26ecff
commit bb37524750
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions

View File

@ -66,7 +66,7 @@ public class ManualFlowControlClient {
// Note: the onReadyHandler's invocation is serialized on the same thread pool as the incoming
// StreamObserver's onNext(), onError(), and onComplete() handlers. Blocking the onReadyHandler will prevent
// additional messages from being processed by the incoming StreamObserver. The onReadyHandler must return
// in a timely manor or else message processing throughput will suffer.
// in a timely manner or else message processing throughput will suffer.
requestStream.setOnReadyHandler(new Runnable() {
// An iterator is used so we can pause and resume iteration of the request data.
Iterator<String> iterator = names().iterator();

View File

@ -46,8 +46,8 @@ public class ManualFlowControlServer {
//
// Note: the onReadyHandler's invocation is serialized on the same thread pool as the incoming StreamObserver's
// onNext(), onError(), and onComplete() handlers. Blocking the onReadyHandler will prevent additional messages
// from being processed by the incoming StreamObserver. The onReadyHandler must return in a timely manor or else
// message processing throughput will suffer.
// from being processed by the incoming StreamObserver. The onReadyHandler must return in a timely manner or
// else message processing throughput will suffer.
class OnReadyHandler implements Runnable {
// Guard against spurious onReady() calls caused by a race between onNext() and onReady(). If the transport
// toggles isReady() from false to true while onNext() is executing, but before onNext() checks isReady(),