package
0.0.0-20230102091508-02d5eeac7d74
Repository: https://github.com/golang-boy/watermill.git
Documentation: pkg.go.dev
# Functions
BulkRead reads provided amount of messages from the provided channel, until a timeout occurrs or the limit is reached.
BulkReadWithDeduplication reads provided number of messages from the provided channel, ignoring duplicates, until a timeout occurrs or the limit is reached.