Skip to content
This repository has been archived by the owner on May 21, 2024. It is now read-only.

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
Co-authored-by: Mihail Stoykov <[email protected]>
  • Loading branch information
olegbespalov and mstoykov authored Jun 14, 2023
1 parent 930fb5c commit ff38c31
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions grpc/stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit ff38c31

Please sign in to comment.