m-trieu commented on code in PR #27767:
URL: https://github.com/apache/beam/pull/27767#discussion_r1302355008
##########
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/ForwardingClientResponseObserver.java:
##########
@@ -27,23 +27,23 @@
* <p>Used to wrap existing {@link StreamObserver}s to be able to install an
{@link
* ClientCallStreamObserver#setOnReadyHandler(Runnable) onReadyHandler}.
*
- * <p>This is as thread-safe as the undering stream observer that is being
wrapped.
+ * <p>This is as thread-safe as the underlying stream observer that is being
wrapped.
*/
-final class ForwardingClientResponseObserver<ReqT, RespT>
- implements ClientResponseObserver<RespT, ReqT> {
+final class ForwardingClientResponseObserver<ResponseT, RequestT>
Review Comment:
done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
