code: async def _body_callback(self, h11_connection):
          '''
          A callback func to be supplied if the user wants to do something
          directly with the response body's stream.
          '''
          # pylint: disable=not-callable
          while True:
              next_event = await self._recv_event(h11_connection)
              if isinstance(next_event, h11.Data):
                  await self.callback(next_event.data)
              else:
                  return next_evenync def _body_callback(self, h11_connection):
          '''
          A callback func to be supplied if the user wants to do something
          directly with the response body's stream.
          '''
          # pylint: disable=not-callable
          while True:
              next_event = await self._recv_event(h11_connection)
              if isinstance(next_event, h11.Data):
                  await self.callback(next_event.data)
              else:
                  return next_event
docs: A callback func to be supplied if the user wants to do something
          directly with the response body's stream.