Home
last modified time | relevance | path

Searched defs:taskRunner (Results 1 – 1 of 1) sorted by relevance

/development/tools/repo_diff/service/repodiff/interactors/
Drunner.go9 type taskRunner struct { struct
10 errorChan chan error
11 sync.Mutex
12 sync.WaitGroup
19 func (t *taskRunner) ExecuteFunctionsAsync(functions []func() error) error {
30 func (t *taskRunner) breakOnError() error {
34 func (t *taskRunner) syncErrorFnToAsync(functions []func() error) []func() {
42 func (t *taskRunner) closeErrorChanOnComplete() {
47 func (t *taskRunner) spawnTasksAsync(tasks []func()) {
54 func (t *taskRunner) redirectErrToChannel(f func() error) func() {