Method get

onchain/eth_get.go:17–60

(f getFunc)

type getFunc func(ctx context.Context) (chan interface{}, chan error)

func (e *ethAdaptor) get(f getFunc) (result interface{}, err error) {
	if !e.isConnecting() {
		err = errors.New("not connecting to geth")
		return
	}
	var valList []chan interface{}
	var errList []chan error
	for _, ctx := range e.ctxes {
		select {
		case <-ctx.Done():
		default:
			opCtx, opCancel := context.WithTimeout(ctx, e.getTimeout)
			defer opCancel()
			outc, errc := f(opCtx)
			valList = append(valList, outc)
			errList = append(errList, errc)
		}
	}
	outc := first(e.ctx, merge(e.ctx, valList...))
	errc := mergeError(e.ctx, errList...)
	var ok bool
	select {
	case result = <-outc:
	case <-e.ctx.Done():
		return nil, errors.Errorf(" : %w", e.ctx.Err())
	}
	for {
		select {
		case err, ok = <-errc:
			if !ok {
				return
			}
			if strings.Contains(err.Error(), "use of closed network connection") {
				var oError *OnchainError
				if errors.As(err, &oError) {
					e.cancels[oError.Idx]()
				}
			}
			continue
		case <-e.ctx.Done():
			return nil, errors.Errorf(" : %w", e.ctx.Err())
		}
	}
}

// GroupToPick returns the groupToPick value
func (e *ethAdaptor) GroupToPick() (result uint64, err error) {