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