Fetch is used to retrieve up to a provided number of messages from a stream. This method will send a single request and deliver either all requested messages unless the timeout is met earlier. Fetch timeout defaults to 30 seconds and can be configured using FetchMaxWait option. By default, Fetch us
(batch int, opts ...FetchOpt)
| 73 | // perform any optimizations (e.g. overlapping pull requests) and new |
| 74 | // subscription is created for each execution. |
| 75 | Fetch(batch int, opts ...FetchOpt) (MessageBatch, error) |
| 76 | |
| 77 | // FetchBytes is used to retrieve up to a provided number of bytes from |
| 78 | // the stream. This method will send a single request and deliver the |
no outgoing calls