From dd9d84d1a9f28993cae63744f8d8ce17e20870e6 Mon Sep 17 00:00:00 2001
From: Yashash H L <yashashhl25@gmail.com>
Date: Thu, 26 Sep 2024 08:19:29 +0530
Subject: [PATCH] Apply suggestions from code review

Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Co-authored-by: Vigith Maurice <vigith@gmail.com>
---
 pkg/sinker/service.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pkg/sinker/service.go b/pkg/sinker/service.go
index 60405e71..82cd59b8 100644
--- a/pkg/sinker/service.go
+++ b/pkg/sinker/service.go
@@ -96,8 +96,10 @@ func (fs *Service) SinkFn(stream sinkpb.Sink_SinkFnServer) error {
 		// Wait for the goroutines to finish
 		if err := g.Wait(); err != nil {
 			if errors.Is(err, io.EOF) {
+				log.Printf("Stopping the SinkFn")
 				return nil
 			}
+			log.Printf("Stopping the SinkFn with err, %s", err)
 			return err
 		}
 	}