|
|
|
@ -134,9 +134,9 @@ def _handle_event(event, state, response_deserializer): |
|
|
|
|
for batch_operation in event.batch_operations: |
|
|
|
|
operation_type = batch_operation.type |
|
|
|
|
state.due.remove(operation_type) |
|
|
|
|
if operation_type is cygrpc.OperationType.receive_initial_metadata: |
|
|
|
|
if operation_type == cygrpc.OperationType.receive_initial_metadata: |
|
|
|
|
state.initial_metadata = batch_operation.received_metadata |
|
|
|
|
elif operation_type is cygrpc.OperationType.receive_message: |
|
|
|
|
elif operation_type == cygrpc.OperationType.receive_message: |
|
|
|
|
serialized_response = batch_operation.received_message.bytes() |
|
|
|
|
if serialized_response is not None: |
|
|
|
|
response = _common.deserialize( |
|
|
|
@ -146,7 +146,7 @@ def _handle_event(event, state, response_deserializer): |
|
|
|
|
_abort(state, grpc.StatusCode.INTERNAL, details) |
|
|
|
|
else: |
|
|
|
|
state.response = response |
|
|
|
|
elif operation_type is cygrpc.OperationType.receive_status_on_client: |
|
|
|
|
elif operation_type == cygrpc.OperationType.receive_status_on_client: |
|
|
|
|
state.trailing_metadata = batch_operation.received_metadata |
|
|
|
|
if state.code is None: |
|
|
|
|
code = _common.CYGRPC_STATUS_CODE_TO_STATUS_CODE.get( |
|
|
|
|