From 8be1251e2c5e15b0439fcdcc6b00dd2232e43d3c Mon Sep 17 00:00:00 2001 From: Lidi Zheng Date: Wed, 29 Apr 2020 15:37:15 -0700 Subject: [PATCH] Remove read/write API && simplify the logic of getting the pool --- .../grpc/_cython/_cygrpc/aio/server.pyx.pxi | 18 +----------------- 1 file changed, 1 insertion(+), 17 deletions(-) diff --git a/src/python/grpcio/grpc/_cython/_cygrpc/aio/server.pyx.pxi b/src/python/grpcio/grpc/_cython/_cygrpc/aio/server.pyx.pxi index b92d681aba0..7ca16e23198 100644 --- a/src/python/grpcio/grpc/_cython/_cygrpc/aio/server.pyx.pxi +++ b/src/python/grpcio/grpc/_cython/_cygrpc/aio/server.pyx.pxi @@ -220,18 +220,6 @@ cdef class _SyncServicerContext: self._callbacks = [] self._loop = context._loop - def read(self): - future = asyncio.run_coroutine_threadsafe( - self._context.read(), - self._loop) - return future.result() - - def write(self, object message): - future = asyncio.run_coroutine_threadsafe( - self._context.write(message), - self._loop) - future.result() - def abort(self, object code, str details='', @@ -959,8 +947,4 @@ cdef class AioServer: cdef thread_pool(self): """Access the thread pool instance.""" - if self._thread_pool: - return self._thread_pool - else: - # Use the event loop's default executor - return None + return self._thread_pool