code: def _multiplexed_response_stream_helper(self, response):
          
  
          # Disable timeout on the underlying socket to prevent
          # Read timed out(s) for long running processes
          socket = self._get_raw_response_socket(response)
          self._disable_socket_timeout(socket)
  
          while True:
              header = response.raw.read(STREAM_HEADER_SIZE_BYTES)
              if not header:
                  break
              _, length = struct.unpack('>BxxxL', header)
              if not length:
                  continue
              data = response.raw.read(length)
              if not data:
                  break
              yield data
docs: A generator of multiplexed data blocks coming from a response
          stream.