From a32d4675d449bb3a49cb63ff196786a85b56a935 Mon Sep 17 00:00:00 2001
From: Antonio Mika <antoniomika@gmail.com>
Date: Sun, 17 Nov 2024 18:28:51 -0500
Subject: [PATCH] Fix base reader

---
 pipe/client.go  | 2 +-
 pipe/session.go | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/pipe/client.go b/pipe/client.go
index 9f09f4a..7fe5730 100644
--- a/pipe/client.go
+++ b/pipe/client.go
@@ -253,7 +253,7 @@ func Base(ctx context.Context, logger *slog.Logger, info *SSHClientInfo, id, cmd
 		return nil, err
 	}
 
-	session, err := client.AddSession(id, cmd, 0, 0, 0)
+	session, err := client.AddSession(id, cmd, 100, -1, -1)
 	if err != nil {
 		return nil, err
 	}
diff --git a/pipe/session.go b/pipe/session.go
index bdf616d..8755fae 100644
--- a/pipe/session.go
+++ b/pipe/session.go
@@ -193,7 +193,7 @@ func (s *Session) Start() {
 					n, err := s.StdoutPipe.Read(data)
 
 					select {
-					case s.Out <- SendData{Data: slices.Clone(data[:n]), N: n, Error: err}:
+					case s.Out <- SendData{Data: data[:n], N: n, Error: err}:
 						break
 					case <-s.Done:
 						s.broadcastDone()
@@ -287,5 +287,7 @@ func (s *Session) broadcastDone() {
 		break
 	case <-s.Client.CtxDone:
 		break
+	default:
+		break
 	}
 }