fix: broken restarting command

cfoust · Jun 19, 2024 · e6a1d5a · e6a1d5a
1 parent c9cfb68
commit e6a1d5a
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/sessions/events.go b/pkg/sessions/events.go
@@ -2,6 +2,7 @@ package sessions
 
 import (
 	"context"
+	"io"
 	"time"
 
 	P "github.com/cfoust/cy/pkg/io/protocol"
@@ -43,6 +44,11 @@ func (s *EventStream) Write(data []byte) (n int, err error) {
 
 func (s *EventStream) Read(p []byte) (n int, err error) {
 	n, err = s.stream.Read(p)
+
+	if n == 0 || err == io.EOF {
+		return n, nil
+	}
+
 	if err != nil {
 		return n, err
 	}