summaryrefslogtreecommitdiff
path: root/internal/server/handlers/serverhandler.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/server/handlers/serverhandler.go')
-rw-r--r--internal/server/handlers/serverhandler.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/internal/server/handlers/serverhandler.go b/internal/server/handlers/serverhandler.go
index 34d2e30..7017f3e 100644
--- a/internal/server/handlers/serverhandler.go
+++ b/internal/server/handlers/serverhandler.go
@@ -85,8 +85,11 @@ func NewServerHandler(handlerCtx, serverCtx context.Context, user *user.User, ca
func (h *ServerHandler) Read(p []byte) (n int, err error) {
for {
select {
-
case message := <-h.serverMessages:
+ if len(message) == 0 {
+ logger.Warn(h.user, "Empty message recieved")
+ return
+ }
if message[0] == '.' {
// Handle hidden message (don't display to the user, interpreted by dtail client)
wholePayload := []byte(fmt.Sprintf("%s\n", message))