diff options
author | 2016-02-22 17:07:27 -0800 | |
---|---|---|
committer | 2016-02-23 02:19:44 +0100 | |
commit | 88966ab1452f015c58664e37569976bc433910fc (patch) | |
tree | c446bc24438422914ecc029864584a30557335db /src/core/surface/lame_client.c | |
parent | f37adb9451330aa82b689e0b3283f20de491a306 (diff) | |
parent | 1dda9926973247a646bca4d0d837cbe04f1ecc82 (diff) |
Merge pull request #5348 from nicolasnoble/backport-merge
Backport merge.
Diffstat (limited to 'src/core/surface/lame_client.c')
-rw-r--r-- | src/core/surface/lame_client.c | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/core/surface/lame_client.c b/src/core/surface/lame_client.c index 705996cad3..537069e984 100644 --- a/src/core/surface/lame_client.c +++ b/src/core/surface/lame_client.c @@ -78,8 +78,7 @@ static void lame_start_transport_stream_op(grpc_exec_ctx *exec_ctx, } else if (op->recv_trailing_metadata != NULL) { fill_metadata(elem, op->recv_trailing_metadata); } - grpc_exec_ctx_enqueue(exec_ctx, op->on_complete, false, NULL); - grpc_exec_ctx_enqueue(exec_ctx, op->recv_message_ready, false, NULL); + grpc_transport_stream_op_finish_with_failure(exec_ctx, op); } static char *lame_get_peer(grpc_exec_ctx *exec_ctx, grpc_call_element *elem) { |