(result json.RawMessage)
| 769 | } |
| 770 | |
| 771 | func (sub *ClientSubscription) deliver(result json.RawMessage) (ok bool) { |
| 772 | select { |
| 773 | case sub.in <- result: |
| 774 | return true |
| 775 | case <-sub.quit: |
| 776 | return false |
| 777 | } |
| 778 | } |
| 779 | |
| 780 | func (sub *ClientSubscription) start() { |
| 781 | sub.quitWithError(sub.forward()) |
no outgoing calls
no test coverage detected