Start separate goroutine for multiplexed stream handling

socket.go

@@ -94,14 +94,18 @@ func startSocket(ctx context.Context, dev *infinitime.Device) error {
 				log.Fatal().Err(err).Msg("Error creating multiplexed session")
 			}
 
+			go func() {
 				for {
 					conn, err := sess.Accept()
-				if err != nil {
+					if errors.Is(err, io.EOF) {
+						break
+					} else if err != nil {
 						log.Fatal().Err(err).Msg("Error accepting stream")
 					}
 
 					go srv.ServeOne(ctx, conn)
 				}
+			}()
 		}
 	}()