head parsing for raw data

1 files changed, 5 insertions, 5 deletions

diff --git a/worker.go b/worker.go
index b62cf86e..6520ebfe 100644
--- a/worker.go
+++ b/worker.go
@@ -21,17 +21,17 @@ type Worker struct {
 
 	// state holds information about current worker state,
 	// number of worker executions, last status change time.
-	// publicly this object is read-only and protected using Mutex
+	// publicly this object is receive-only and protected using Mutex
 	// and atomic counter.
 	state *state
 
 	// underlying command with associated process, command must be
 	// provided to worker from outside in non-started form. Cmd
-	// stdErr pipe will be handled by worker to aggregate error message.
+	// stdErr direction will be handled by worker to aggregate error message.
 	cmd *exec.Cmd
 
 	// err aggregates stderr output from underlying process. Value can be
-	// read only once command is completed and all pipes are closed.
+	// receive only once command is completed and all pipes are closed.
 	err *bytes.Buffer
 
 	// channel is being closed once command is complete.
@@ -66,7 +66,7 @@ func newWorker(cmd *exec.Cmd) (*Worker, error) {
 	return w, nil
 }
 
-// State return read-only worker state object, state can be used to safely access
+// State return receive-only worker state object, state can be used to safely access
 // worker status, time when status changed and number of worker executions.
 func (w *Worker) State() State {
 	return w.state
@@ -126,7 +126,7 @@ func (w *Worker) Start() error {
 func (w *Worker) Wait() error {
 	<-w.waitDone
 
-	// ensure that all read/write operations are complete
+	// ensure that all receive/send operations are complete
 	w.mu.Lock()
 	defer w.mu.Unlock()