()
| 847 | } |
| 848 | |
| 849 | func (js *js) asyncStall() <-chan struct{} { |
| 850 | js.mu.Lock() |
| 851 | if js.stc == nil { |
| 852 | js.stc = make(chan struct{}) |
| 853 | } |
| 854 | stc := js.stc |
| 855 | js.mu.Unlock() |
| 856 | return stc |
| 857 | } |
| 858 | |
| 859 | // Handle an async reply from PublishAsync. |
| 860 | func (js *js) handleAsyncReply(m *Msg) { |