// SubmitToSingleCTWithResult mocks base method
185481
func (m *MockPublisher) SubmitToSingleCTWithResult(arg0 context.Context, arg1 *proto.Request) (*proto.Result, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SubmitToSingleCTWithResult", arg0, arg1)
	ret0, _ := ret[0].(*proto.Result)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
656619
func (f *Selectable) GetResult() (interface{}, error) {
	if atomic.LoadUint32(&f.filled) == 0 {
		<-f.wchan()
	}
	return f.val, f.err
}
653632
func (r *AreaSearchResponse) ResultsWithScore(score int) []*Area {
	var res []*Area
	for _, v := range r.Areas {
		if r.Scores[v] >= score {
			res = append(res, v)
		}
	}
	return res
}
780140
func (c *AppversionListCall) EventResult(eventResult string) *AppversionListCall {
	c.urlParams_.Set("eventResult", eventResult)
	return c
}
111842
func (o *RejectLogoutRequestParams) WithLogoutChallenge(logoutChallenge string) *RejectLogoutRequestParams {
	o.SetLogoutChallenge(logoutChallenge)
	return o
}
358643
func NewResultCommit(header *types.Header, commit *types.Commit,
	canonical bool) *ResultCommit {

	return &ResultCommit{
		SignedHeader: types.SignedHeader{
			Header: header,
			Commit: commit,
		},
		CanonicalCommit: canonical,
	}
}
282191
func NewResult(operation Operation, result Result, errMsg ...string) *OperationResult {
	msg := ""
	if len(errMsg) > 0 {
		msg = errMsg[0]
	}
	return &OperationResult{
		Operation:  operation,
		Result:     result,
		ErrMessage: msg,
	}
}
491887
func (bt *BaseTask) WithResultPath(resultPath string) *BaseTask {
	bt.ResultPath = resultPath
	return bt
}
370126
func (req *CodeRequest) StoreResult(db ethdb.Database) {
	db.Put(req.Hash[:], req.Data)
}
347247
func (r *MockResult) Get(i int) interface{} {
	if r.Contains(i) {
		return r.Result[i]
	} else {
		return nil
	}
}
1279945
func (r *ArtistSearchResponse) ResultsWithScore(score int) []*Artist {
	var res []*Artist
	for _, v := range r.Artists {
		if r.Scores[v] >= score {
			res = append(res, v)
		}
	}
	return res
}
386292
func (o *GetPrefilterFailure) WithPayload(payload models.Error) *GetPrefilterFailure {
	o.Payload = payload
	return o
}
60372
func (s *AdminRespondToAuthChallengeOutput) SetAuthenticationResult(v *AuthenticationResultType) *AdminRespondToAuthChallengeOutput {
	s.AuthenticationResult = v
	return s
}
494855
func (s *Scheduler) SubmitWithOptions(ctx context.Context, app *twelvefactor.Manifest, ss twelvefactor.StatusStream, opts SubmitOptions) error {
	tx, err := s.db.Begin()
	if err != nil {
		return err
	}

	err = s.submit(ctx, tx, app, ss, opts)
	if err != nil {
		tx.Rollback()
		return err
	}
	return tx.Commit()
}
155245
func (sf *sumFunction) GetResult(evalCtx *AggEvaluateContext) (d types.Datum) {
	return evalCtx.Value
}
103762
func (prod *AwsCloudwatchLogs) handleResult(resp *cloudwatchlogs.PutLogEventsOutput, result error) {
	switch err := result.(type) {
	case awserr.Error:
		switch err.Code() {
		case "InvalidSequenceTokenException":
			prod.Logger.Debugf("invalid sequence token, updating")
			prod.setToken()
		case "ResourceNotFoundException":
			prod.Logger.Debugf("missing group/stream, creating")
			prod.create()
			prod.token = nil
		default:
			prod.Logger.Errorf("error while sending batch. code: %s message: %q", err.Code(), err.Message())
		}
	case nil:
		prod.token = resp.NextSequenceToken
	default:
		prod.Logger.Errorf("error while sending batch: %q", err)
	}
}
51797
func (o *AcceptConsentRequestParams) WithConsentChallenge(consentChallenge string) *AcceptConsentRequestParams {
	o.SetConsentChallenge(consentChallenge)
	return o
}