From 2c21c7be894c187b3cdb884f5d22fe4f9da85377 Mon Sep 17 00:00:00 2001 From: Ethan Buchman Date: Wed, 22 Jun 2016 14:25:18 -0400 Subject: [PATCH] call reqRes.SetDone in grpc client --- client/grpc_client.go | 1 + 1 file changed, 1 insertion(+) diff --git a/client/grpc_client.go b/client/grpc_client.go index 3fbd000b..a1c51410 100644 --- a/client/grpc_client.go +++ b/client/grpc_client.go @@ -197,6 +197,7 @@ func (cli *grpcClient) finishAsyncCall(req *types.Request, res *types.Response) reqres := NewReqRes(req) reqres.Response = res // Set response reqres.Done() // Release waiters + reqres.SetDone() // so reqRes.SetCallback will run the callback // Notify reqRes listener if set if cb := reqres.GetCallback(); cb != nil {