Skip to content

Commit

Permalink
fix(pubsub): convert stream ack deadline seconds from duration (#11214)
Browse files Browse the repository at this point in the history
* fix(pubsub): convert stream ack deadline seconds from duration

* call Duration.Seconds instead
  • Loading branch information
hongalex authored Dec 4, 2024
1 parent 63b704e commit b2b05e4
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pubsub/iterator.go
Original file line number Diff line number Diff line change
Expand Up @@ -893,7 +893,7 @@ func (it *messageIterator) pingStream() {
spr := &pb.StreamingPullRequest{}
it.eoMu.RLock()
if it.sendNewAckDeadline {
spr.StreamAckDeadlineSeconds = int32(it.ackDeadline())
spr.StreamAckDeadlineSeconds = int32(it.ackDeadline().Seconds())
it.sendNewAckDeadline = false
}
it.eoMu.RUnlock()
Expand Down

0 comments on commit b2b05e4

Please sign in to comment.