FetchNoWait is used to retrieve up to a provided number of messages from a stream. Unlike Fetch, FetchNoWait will only deliver messages that are currently available in the stream and will not wait for new messages to arrive, even if batch size is not met. FetchNoWait is non-blocking and returns Mes
(batch int)
| 118 | // does not perform any optimizations (e.g. overlapping pull requests) |
| 119 | // and new subscription is created for each execution. |
| 120 | FetchNoWait(batch int) (MessageBatch, error) |
| 121 | |
| 122 | // Consume will continuously receive messages and handle them |
| 123 | // with the provided callback function. Consume can be configured using |
no outgoing calls