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

Commit

Permalink
a better logging
Browse files Browse the repository at this point in the history
  • Loading branch information
olegbespalov committed Sep 11, 2023
1 parent a74405c commit a55759f
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion grpc/stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -325,7 +325,7 @@ func (s *stream) end() {
return
}

s.logger.Debug("stream is closing")
s.logger.Debugf("finishing stream %s writing", s.method)

s.writingState = closed
s.writeQueueCh <- message{isClosing: true}
Expand All @@ -351,6 +351,7 @@ func (s *stream) close(err error) {
default:
}

s.logger.Debugf("stream %s is closing", s.method)
close(s.done)

s.tq.Queue(func() error {
Expand Down

0 comments on commit a55759f

Please sign in to comment.