Skip to content

Commit

Permalink
Add InitializeNewTask method for ServiceHandler
Browse files Browse the repository at this point in the history
  • Loading branch information
maximopalopoli committed Feb 18, 2025
1 parent bff34f4 commit 452f768
Showing 1 changed file with 15 additions and 0 deletions.
15 changes: 15 additions & 0 deletions services/bls_aggregation/blsagg.go
Original file line number Diff line number Diff line change
Expand Up @@ -337,6 +337,21 @@ func (a *BlsAggregatorService) run(
}
}

func (a *ServiceHandler) InitializeNewTask(
metadata TaskMetadata,
) error {
errChan := make(chan error)
a.TaskInitC <- InitializeTaskRequest{metadata, errChan}
select {
case err := <-errChan:
return err
default:
return nil
}
}

// TODO: continue by adding the process signature option

func (a *BlsAggregatorService) GetResponseChannel() <-chan BlsAggregationServiceResponse {
return a.aggregatedResponsesC
}
Expand Down

0 comments on commit 452f768

Please sign in to comment.