diff --git a/transport/http2_client.go b/transport/http2_client.go index 9cc754f7..0226b43f 100644 --- a/transport/http2_client.go +++ b/transport/http2_client.go @@ -219,6 +219,7 @@ func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (_ *Strea } if uint32(len(t.activeStreams)) >= t.maxStreams { t.mu.Unlock() + t.writableChan <- 0 return nil, StreamErrorf(codes.Unavailable, "transport: failed to create new stream because the limit has been reached.") } s := t.newStream(ctx, callHdr)