()
| 798 | } |
| 799 | |
| 800 | func (js *js) cleanupReplySub() { |
| 801 | js.mu.Lock() |
| 802 | if js.rsub != nil { |
| 803 | js.rsub.Unsubscribe() |
| 804 | js.rsub = nil |
| 805 | } |
| 806 | if js.connStatusCh != nil { |
| 807 | close(js.connStatusCh) |
| 808 | js.connStatusCh = nil |
| 809 | } |
| 810 | js.mu.Unlock() |
| 811 | } |
| 812 | |
| 813 | // registerPAF will register for a PubAckFuture. |
| 814 | func (js *js) registerPAF(id string, paf *pubAckFuture) (int, int) { |
no test coverage detected