()
| 638 | } |
| 639 | |
| 640 | func (js *jetStream) asyncStall() <-chan struct{} { |
| 641 | js.publisher.Lock() |
| 642 | if js.publisher.stallCh == nil { |
| 643 | js.publisher.stallCh = make(chan struct{}) |
| 644 | } |
| 645 | stc := js.publisher.stallCh |
| 646 | js.publisher.Unlock() |
| 647 | return stc |
| 648 | } |
| 649 | |
| 650 | func (paf *pubAckFuture) Ok() <-chan *PubAck { |
| 651 | paf.jsClient.Lock() |