|
|
@ -264,14 +264,10 @@ async def _finish_handler_with_unary_response(RPCState rpc_state, |
|
|
|
rpc_state.raise_for_termination() |
|
|
|
rpc_state.raise_for_termination() |
|
|
|
|
|
|
|
|
|
|
|
# Serializes the response message |
|
|
|
# Serializes the response message |
|
|
|
cdef bytes response_raw |
|
|
|
cdef bytes response_raw = serialize( |
|
|
|
if rpc_state.status_code == StatusCode.ok: |
|
|
|
response_serializer, |
|
|
|
response_raw = serialize( |
|
|
|
response_message, |
|
|
|
response_serializer, |
|
|
|
) |
|
|
|
response_message, |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
else: |
|
|
|
|
|
|
|
response_raw = b'' |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# Assembles the batch operations |
|
|
|
# Assembles the batch operations |
|
|
|
cdef tuple finish_ops |
|
|
|
cdef tuple finish_ops |
|
|
|