diff options
Diffstat (limited to 'pkg/tasks/async_handler.go')
| -rw-r--r-- | pkg/tasks/async_handler.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/pkg/tasks/async_handler.go b/pkg/tasks/async_handler.go index 6f3f41b29..658687af9 100644 --- a/pkg/tasks/async_handler.go +++ b/pkg/tasks/async_handler.go @@ -18,10 +18,10 @@ type AsyncHandler struct { lastId int mutex deadlock.Mutex onReject func() - onWorker func(func(gocui.Task)) + onWorker func(func(gocui.Task) error) } -func NewAsyncHandler(onWorker func(func(gocui.Task))) *AsyncHandler { +func NewAsyncHandler(onWorker func(func(gocui.Task) error)) *AsyncHandler { return &AsyncHandler{ mutex: deadlock.Mutex{}, onWorker: onWorker, @@ -34,9 +34,10 @@ func (self *AsyncHandler) Do(f func() func()) { id := self.currentId self.mutex.Unlock() - self.onWorker(func(gocui.Task) { + self.onWorker(func(gocui.Task) error { after := f() self.handle(after, id) + return nil }) } |