def on_response_body()

in callouts/python/extproc/example/e2e_tests/observability_server.py [0:0]

• 7 lines of code
• 3 McCabe index (conditional complexity)

  def on_response_body(self, body: service_pb2.HttpBody,
                       context: ServicerContext) -> BodyResponse:
    """Custom processor on the response body."""
    logging.info('on_response_body %s', body)
    with lock:
      if (not body.end_of_stream or body.body):
        counters['response_body_count'] += 1
    return BodyResponse()