|
|
@ -95,8 +95,8 @@ class _CacheInterceptor(aio.ServerInterceptor): |
|
|
|
handler = await continuation(handler_call_details) |
|
|
|
handler = await continuation(handler_call_details) |
|
|
|
|
|
|
|
|
|
|
|
# Only intercept unary call RPCs |
|
|
|
# Only intercept unary call RPCs |
|
|
|
if handler and (handler.request_streaming or |
|
|
|
if handler and (handler.request_streaming or # pytype: disable=attribute-error |
|
|
|
handler.response_streaming): |
|
|
|
handler.response_streaming): # pytype: disable=attribute-error |
|
|
|
return handler |
|
|
|
return handler |
|
|
|
|
|
|
|
|
|
|
|
def wrapper(behavior: Callable[ |
|
|
|
def wrapper(behavior: Callable[ |
|
|
|