diff options
Diffstat (limited to 'worker.go')
| -rw-r--r-- | worker.go | 6 |
1 files changed, 3 insertions, 3 deletions
@@ -36,7 +36,7 @@ type Worker struct { // err aggregates stderr output from underlying process. Value can be // receive only once command is completed and all pipes are closed. - err *buffer + err *errBuffer // channel is being closed once command is complete. waitDone chan interface{} @@ -60,12 +60,12 @@ func newWorker(cmd *exec.Cmd) (*Worker, error) { w := &Worker{ Created: time.Now(), cmd: cmd, - err: &buffer{buffer: new(bytes.Buffer)}, + err: &errBuffer{buffer: new(bytes.Buffer)}, waitDone: make(chan interface{}), state: newState(StateInactive), } - // piping all stderr to command buffer + // piping all stderr to command errBuffer w.cmd.Stderr = w.err return w, nil |