(ch chan p2pRequest)
| 33 | return |
| 34 | } |
| 35 | func (r *p2pRequest) sendReq(ch chan p2pRequest) (err error) { |
| 36 | select { |
| 37 | case ch <- *r: |
| 38 | case <-r.ctx.Done(): |
| 39 | err = r.ctx.Err() |
| 40 | fmt.Println("p2pRequest sendReq err", err) |
| 41 | } |
| 42 | return |
| 43 | } |
| 44 | |
| 45 | func (r *p2pRequest) waitForResult() (res interface{}, err error) { |
| 46 | select { |