From ff38c3180ecf5d93d4f86603f77641c18774ba1e Mon Sep 17 00:00:00 2001 From: Oleg Bespalov Date: Wed, 14 Jun 2023 16:20:37 +0200 Subject: [PATCH] Apply suggestions from code review Co-authored-by: Mihail Stoykov <312246+mstoykov@users.noreply.github.com> --- grpc/stream.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/grpc/stream.go b/grpc/stream.go index d338b9b..fc1bf89 100644 --- a/grpc/stream.go +++ b/grpc/stream.go @@ -290,10 +290,10 @@ func (s *stream) processSendError(err error) { return } + s.logger.WithError(err).Error("failed to send data to the stream") s.tq.Queue(func() error { - return s.closeWithError(nil) + return s.closeWithError(err) }) - s.logger.WithError(err).Error("failed to send data to the stream") } // on registers a listener for a certain event type