Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
steden committed Apr 5, 2024
1 parent 49711de commit 3d54a30
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pullMessage.go
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ func (receiver *subscriber) isHaveMessage() bool {
receiver.queueManager.work()
defer receiver.queueManager.unWork()

return receiver.queueManager.queue.Count()-receiver.offset-1 > 0
return receiver.queueManager.queue.Count() - receiver.offset-1 > 0
}

// 计算本次可以消费的数量
Expand Down

0 comments on commit 3d54a30

Please sign in to comment.