PublishAsyncPending returns the number of async publishes outstanding for this context. An outstanding publish is one that has been sent by the publisher but has not yet received an ack.
()
| 104 | // for this context. An outstanding publish is one that has been |
| 105 | // sent by the publisher but has not yet received an ack. |
| 106 | PublishAsyncPending() int |
| 107 | |
| 108 | // PublishAsyncComplete returns a channel that will be closed when all |
| 109 | // outstanding asynchronously published messages are acknowledged by the |
no outgoing calls