diff --git a/tasklog/log.go b/tasklog/log.go index 9484edb5..e9f7f8fe 100644 --- a/tasklog/log.go +++ b/tasklog/log.go @@ -115,7 +115,7 @@ func (l *Logger) Close() { l.wg.Wait() } -// Waitier creates and enqueues a new *WaitingTask. +// Waiter creates and enqueues a new *WaitingTask. func (l *Logger) Waiter(msg string) *WaitingTask { t := NewWaitingTask(msg) l.Enqueue(t) @@ -139,7 +139,7 @@ func (l *Logger) List(msg string) *ListTask { return t } -// List creates and enqueues a new *SimpleTask. +// Simple creates and enqueues a new *SimpleTask. func (l *Logger) Simple() *SimpleTask { t := NewSimpleTask() l.Enqueue(t) diff --git a/tasklog/waiting_task.go b/tasklog/waiting_task.go index bfae2d67..3bf969eb 100644 --- a/tasklog/waiting_task.go +++ b/tasklog/waiting_task.go @@ -28,8 +28,8 @@ func (w *WaitingTask) Complete() { close(w.ch) } -// Done implements Task.Done and returns a channel which is closed when -// Complete() is called. +// Updates implements the Task.Updates function and returns a channel of updates +// to log to the sink. func (w *WaitingTask) Updates() <-chan *Update { return w.ch }