Method replyResult

p2p/request.go:57–65

(res interface{}, err error)

}

func (r *p2pRequest) replyResult(res interface{}, err error) {
	r.once.Do(func() {
		defer close(r.reply)
		select {
		case <-r.ctx.Done():
		case r.reply <- p2pResult{res: res, err: err}:
		}
	})
}