Closed returns a channel that is closed when the consuming is fully stopped/drained. When the channel is closed, no more messages will be received and processing is complete.
()
| 68 | // fully stopped/drained. When the channel is closed, no more messages |
| 69 | // will be received and processing is complete. |
| 70 | Closed() <-chan struct{} |
| 71 | } |
| 72 | |
| 73 | // MessageHandler is a handler function used as callback in [Consume]. |
no outgoing calls