diff options
author | 2018-03-12 10:37:52 -0700 | |
---|---|---|
committer | 2018-03-12 10:37:52 -0700 | |
commit | 1d603248f29493d9faca01999d7e793a48a5b1fd (patch) | |
tree | 0b2e188907bf1b8cc1eecec8a0f0a7c6a5bcb92a /include/grpcpp/impl/codegen | |
parent | d10a885922387c7237dc5d26ec4db8c1474a70cd (diff) |
forgot to add completion_queue.h doh!
Diffstat (limited to 'include/grpcpp/impl/codegen')
-rw-r--r-- | include/grpcpp/impl/codegen/completion_queue.h | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/include/grpcpp/impl/codegen/completion_queue.h b/include/grpcpp/impl/codegen/completion_queue.h index 86fa634df8..ea43777bfc 100644 --- a/include/grpcpp/impl/codegen/completion_queue.h +++ b/include/grpcpp/impl/codegen/completion_queue.h @@ -165,7 +165,11 @@ class CompletionQueue : private GrpcLibraryCodegen { /// /// \return true if got an event, false if the queue is fully drained and /// shut down. - virtual bool Next(void** tag, bool* ok); + bool Next(void** tag, bool* ok) { + return (AsyncNextInternal(tag, ok, + g_core_codegen_interface->gpr_inf_future( + GPR_CLOCK_REALTIME)) != SHUTDOWN); + } /// Read from the queue, blocking up to \a deadline (or the queue's shutdown). /// Both \a tag and \a ok are updated upon success (if an event is available |