func (manager *EthSubsManager) NewWorker(helper *worker.Helper) (wroker worker.Worker, err error) {
	jobInfo := new(ethtypes.EthSubsJobInfo)
	json.Unmarshal(helper.Job().Data, jobInfo)
	
	handler := manager.handlers[jobInfo.Handler]
	
	if handler == nil {
		err = errors.New("Unknown Log Handler " + jobInfo.Handler)
		helper.Error("[ERROR-EthSubsManager] Unknown Log Handler ", jobInfo.Handler)
		return nil, err
	}
	
	subscriber := EthSubscriber{id: helper.ID(), jobInfo: jobInfo, networkURL: manager.networkURL,
		helper: helper, handler: handler}
	
	return &subscriber, err
}
// NewWorker implements worker.Factory.NewWorker
NewWorker implements worker.Factory.NewWorker
// NewWorker implements worker . Factory . NewWorker
func (manager *EthSubsManager) NewWorker(helper *worker.Helper) (wroker worker.Worker, err error) {
	jobInfo := new(ethtypes.EthSubsJobInfo)
	json.Unmarshal(helper.Job().Data, jobInfo)
	handler := manager.handlers[jobInfo.Handler]
	if handler == nil {
		err = errors.New("Unknown Log Handler " + jobInfo.Handler)
		helper.Error("[ERROR-EthSubsManager] Unknown Log Handler ", jobInfo.Handler)
		return nil, err
	}
	subscriber := EthSubscriber{id: helper.ID(), jobInfo: jobInfo, networkURL: manager.networkURL,
		helper: helper, handler: handler}
	return &subscriber, err
}
func ( manager * EthSubsManager ) NewWorker ( helper * worker . Helper ) ( wroker worker . Worker , err error ) { jobInfo := new ( ethtypes . EthSubsJobInfo ) json . Unmarshal ( helper . Job ( ) . Data , jobInfo ) handler := manager . handlers [ jobInfo . Handler ] if handler == nil { err = errors . New ( " " + jobInfo . Handler ) helper . Error ( " " , jobInfo . Handler ) return nil , err } subscriber := EthSubscriber { id : helper . ID ( ) , jobInfo : jobInfo , networkURL : manager . networkURL , helper : helper , handler : handler } return & subscriber , err }
NewWorker implements worker.Factory.NewWorker
NewWorker implements worker . Factory . NewWorker