diff options
Diffstat (limited to 'exec_response.go')
| -rw-r--r-- | exec_response.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/exec_response.go b/exec_response.go index a5cb1ff..92774cf 100644 --- a/exec_response.go +++ b/exec_response.go @@ -89,6 +89,9 @@ func (execRes *ExecResponse) Write(out []byte) (n int, err error) { // end mark the execution completed, possibly with error. func (execRes *ExecResponse) end(execErr error) { + execRes.mtxOutput.Lock() + defer execRes.mtxOutput.Unlock() + var ev sseclient.Event if execErr != nil { |