From 9beb0c989e5e2210692fd10ffb9dfc1a676773b9 Mon Sep 17 00:00:00 2001 From: Branden J Brown Date: Fri, 2 Feb 2024 20:48:45 -0600 Subject: [PATCH] read heartbeats from queueing players --- server.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/server.go b/server.go index 5a6a330..ad2e710 100644 --- a/server.go +++ b/server.go @@ -197,6 +197,14 @@ func (s *Server) Queue(w http.ResponseWriter, r *http.Request) { func (s *Server) joinAndServe(p person) { slog.Debug("joining", "player", p.id) ctx, stop := context.WithTimeoutCause(context.Background(), 10*time.Minute, errQueueEmpty) + go func() { + for { + _, _, err := p.conn.Read(ctx) + if err != nil { + return + } + } + }() id, chall, deal := s.l.Queue(ctx, p.id) stop() if id == (lobby.GameID{}) {