Drain unsubscribes from the stream and cancels subscription. All messages that are already in the buffer will be processed in callback function.
()
| 63 | // Drain unsubscribes from the stream and cancels subscription. |
| 64 | // All messages that are already in the buffer will be processed in callback function. |
| 65 | Drain() |
| 66 | |
| 67 | // Closed returns a channel that is closed when the consuming is |
| 68 | // fully stopped/drained. When the channel is closed, no more messages |
no outgoing calls