parent
61b6893ec4
commit
5c37d6cd6f
@ -197,7 +197,7 @@ func (s *Server) Queue(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
func (s *Server) joinAndServe(p person) {
|
func (s *Server) joinAndServe(p person) {
|
||||||
slog.Debug("joining", "player", p.id)
|
slog.Debug("joining", "player", p.id)
|
||||||
ctx, stop := context.WithTimeoutCause(context.Background(), 10*time.Minute, errQueueEmpty)
|
ctx, stop := context.WithTimeoutCause(context.Background(), 3*time.Minute, errQueueEmpty)
|
||||||
ch := make(chan struct{})
|
ch := make(chan struct{})
|
||||||
go func() {
|
go func() {
|
||||||
defer close(ch)
|
defer close(ch)
|
||||||
|
Loading…
Reference in New Issue
Block a user