summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJesse Duffield <jessedduffield@gmail.com>2023-07-10 12:09:32 +1000
committerJesse Duffield <jessedduffield@gmail.com>2023-07-10 17:12:21 +1000
commita0154dc5257e6b3f5c6f8bb25836b3aecc671875 (patch)
treebf23b5fdbe53f0839d85004ad8ba6305883cd850
parent6b9390409eb533fe87648be55e9db7d36b1d9ee3 (diff)
Refactor
-rw-r--r--pkg/tasks/tasks.go12
1 files changed, 6 insertions, 6 deletions
diff --git a/pkg/tasks/tasks.go b/pkg/tasks/tasks.go
index e2aed471e..33c46380f 100644
--- a/pkg/tasks/tasks.go
+++ b/pkg/tasks/tasks.go
@@ -186,8 +186,8 @@ func (self *ViewBufferManager) NewCmdTask(start func() (*exec.Cmd, io.Reader), p
go utils.Safe(func() {
isViewStale := true
writeToView := func(content []byte) {
- _, _ = self.writer.Write(content)
isViewStale = true
+ _, _ = self.writer.Write(content)
}
refreshViewIfStale := func() {
if isViewStale {
@@ -299,18 +299,18 @@ type TaskOpts struct {
}
func (self *ViewBufferManager) NewTask(f func(TaskOpts) error, key string) error {
- task := self.newGocuiTask()
+ gocuiTask := self.newGocuiTask()
var completeTaskOnce sync.Once
- completeTask := func() {
+ completeGocuiTask := func() {
completeTaskOnce.Do(func() {
- task.Done()
+ gocuiTask.Done()
})
}
go utils.Safe(func() {
- defer completeTask()
+ defer completeGocuiTask()
self.taskIDMutex.Lock()
self.newTaskID++
@@ -350,7 +350,7 @@ func (self *ViewBufferManager) NewTask(f func(TaskOpts) error, key string) error
self.waitingMutex.Unlock()
- if err := f(TaskOpts{Stop: stop, InitialContentLoaded: completeTask}); err != nil {
+ if err := f(TaskOpts{Stop: stop, InitialContentLoaded: completeGocuiTask}); err != nil {
self.Log.Error(err) // might need an onError callback
}