|
|
@ -140,6 +140,7 @@ cdef class CompletionQueue: |
|
|
|
grpc_completion_queue_shutdown(self.c_completion_queue) |
|
|
|
grpc_completion_queue_shutdown(self.c_completion_queue) |
|
|
|
# Pump the queue |
|
|
|
# Pump the queue |
|
|
|
while not self.is_shutdown: |
|
|
|
while not self.is_shutdown: |
|
|
|
|
|
|
|
with nogil: |
|
|
|
event = grpc_completion_queue_next( |
|
|
|
event = grpc_completion_queue_next( |
|
|
|
self.c_completion_queue, c_deadline, NULL) |
|
|
|
self.c_completion_queue, c_deadline, NULL) |
|
|
|
self._interpret_event(event) |
|
|
|
self._interpret_event(event) |
|
|
|