diff --git a/spanner/session.go b/spanner/session.go index 75ee0fd6b424..6b66746550bb 100644 --- a/spanner/session.go +++ b/spanner/session.go @@ -1067,6 +1067,7 @@ func (p *sessionPool) close(ctx context.Context) { } p.mu.Unlock() p.hc.close() + close(p.multiplexedSessionReq) // destroy all the sessions p.hc.mu.Lock() allSessions := make([]*session, len(p.hc.queue.sessions))