From 43a92f3fe6c85c1e9aaac6d18cbe58ec32821d21 Mon Sep 17 00:00:00 2001 From: iamqizhao Date: Tue, 31 Mar 2015 10:47:30 -0700 Subject: [PATCH] small fix --- transport/http2_client.go | 1 + 1 file changed, 1 insertion(+) 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)