def _stream_helper(self, response, decode=False):
        """Generator for data coming from a chunked-encoded HTTP response."""

        if response.raw._fp.chunked:
            if decode:
                for chunk in json_stream(self._stream_helper(response, False)):
                    yield chunk
            else:
                reader = response.raw
                while not reader.closed:
                    # this read call will block until we get a chunk
                    data = reader.read(1)
                    if not data:
                        break
                    if reader._fp.chunk_left:
                        data += reader.read(reader._fp.chunk_left)
                    yield data
        else:
            # Response isn't chunked, meaning we probably
            # encountered an error immediately
            yield self._result(response, json=decode)
def _stream_helper ( self , response , decode = False ) : if response . raw . _fp . chunked : if decode : for chunk in json_stream ( self . _stream_helper ( response , False ) ) : yield chunk else : reader = response . raw while not reader . closed : data = reader . read ( 1 ) if not data : break if reader . _fp . chunk_left : data += reader . read ( reader . _fp . chunk_left ) yield data else : yield self . _result ( response , json = decode )
Generator for data coming from a chunked-encoded HTTP response.