comments

Signed-off-by: Yashash H L <[email protected]>
numaproj · Sep 21, 2024 · b8c595f · b8c595f
1 parent 7ae0a60
commit b8c595f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/io/numaproj/numaflow/sourcer/Service.java b/src/main/java/io/numaproj/numaflow/sourcer/Service.java
@@ -32,6 +32,7 @@ public StreamObserver<SourceOuterClass.ReadRequest> readFn(final StreamObserver<
         return new StreamObserver<>() {
             @Override
             public void onNext(SourceOuterClass.ReadRequest request) {
+                // if the request is a handshake, send handshake response.
                 if (request.hasHandshake() && request.getHandshake().getSot()) {
                     responseObserver.onNext(SourceOuterClass.ReadResponse.newBuilder()
                             .setHandshake(request.getHandshake())