diff options
Diffstat (limited to 'exec_response.go')
| -rw-r--r-- | exec_response.go | 31 |
1 files changed, 8 insertions, 23 deletions
diff --git a/exec_response.go b/exec_response.go index 9665187..ce97198 100644 --- a/exec_response.go +++ b/exec_response.go @@ -4,7 +4,6 @@ package awwan import ( - "bytes" "fmt" "strconv" "sync" @@ -71,31 +70,17 @@ func (execRes *ExecResponse) Write(out []byte) (n int, err error) { return 0, nil } - var outlen = len(out) - if out[outlen-1] == '\n' { - out = out[:outlen-1] - } - - var ( - lines = bytes.Split(out, []byte{'\n'}) - - line []byte - ev sseclient.Event - ) - execRes.mtxOutput.Lock() - for _, line = range lines { - ev = sseclient.Event{ - Data: string(line), - ID: strconv.FormatInt(int64(len(execRes.Output)), 10), - } + var ev = sseclient.Event{ + Data: string(out), + ID: strconv.FormatInt(int64(len(execRes.Output)), 10), + } - execRes.Output = append(execRes.Output, ev.Data) + execRes.Output = append(execRes.Output, ev.Data) - select { - case execRes.eventq <- ev: - default: - } + select { + case execRes.eventq <- ev: + default: } execRes.mtxOutput.Unlock() |