@ -25,6 +25,7 @@ from grpc._cython import cygrpc
from grpc.framework.foundation import callable_util
_LOGGER = logging.getLogger(__name__)
_LOGGER.addHandler(logging.NullHandler())
_USER_AGENT = 'grpc-python/{}'.format(_grpcio_metadata.__version__)
@ -21,6 +21,7 @@ import grpc
from grpc._cython import cygrpc
CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY = {
cygrpc.ConnectivityState.idle:
@ -15,6 +15,7 @@
import logging
# This function will ascii encode unicode string inputs if neccesary.
# In Python3, unicode strings are the default str type.
@ -19,6 +19,7 @@ import time
import grpc
cdef class Server:
@ -21,6 +21,7 @@ from grpc import _common
class _AuthMetadataContext(
@ -22,6 +22,7 @@ import logging
import six
class Outcome(six.with_metaclass(abc.ABCMeta)):
@ -18,6 +18,7 @@ import logging
from concurrent import futures
def _wrap(behavior):
@ -20,6 +20,7 @@ from grpc.framework.foundation import stream
_NO_VALUE = object()
class TransformingConsumer(stream.Consumer):