Versions in this module Expand all Collapse all v1 v1.3.5 Jun 6, 2024 Changes in this version + func BulkRead(messagesCh <-chan *message.Message, limit int, timeout time.Duration) (receivedMessages message.Messages, all bool) + func BulkReadWithDeduplication(messagesCh <-chan *message.Message, limit int, timeout time.Duration) (receivedMessages message.Messages, all bool)
Go to main page