clearPAF will remove a PubAckFuture that was registered.
(id string)
| 632 | |
| 633 | // clearPAF will remove a PubAckFuture that was registered. |
| 634 | func (js *jetStream) clearPAF(id string) { |
| 635 | js.publisher.Lock() |
| 636 | delete(js.publisher.acks, id) |
| 637 | js.publisher.Unlock() |
| 638 | } |
| 639 | |
| 640 | func (js *jetStream) asyncStall() <-chan struct{} { |
| 641 | js.publisher.Lock() |