clearPAF will remove a PubAckFuture that was registered.
(id string)
| 834 | |
| 835 | // clearPAF will remove a PubAckFuture that was registered. |
| 836 | func (js *js) clearPAF(id string) { |
| 837 | js.mu.Lock() |
| 838 | delete(js.pafs, id) |
| 839 | js.mu.Unlock() |
| 840 | } |
| 841 | |
| 842 | // PublishAsyncPending returns how many PubAckFutures are pending. |
| 843 | func (js *js) PublishAsyncPending() int { |