def row_iterator()

in azure-kusto-data/azure/kusto/data/streaming_response.py [0:0]

• 9 lines of code
• 6 McCabe index (conditional complexity)

    def row_iterator(self) -> Iterator[list]:
        self.reader.read_token_of_type(JsonTokenType.START_ARRAY)
        while True:
            token = self.reader.read_token_of_type(JsonTokenType.START_ARRAY, JsonTokenType.END_ARRAY, JsonTokenType.START_MAP)
            if token.token_type == JsonTokenType.START_MAP:
                # Todo - this method of error handling may be problematic, since after raising an error the iteration stops.
                #  This means that if there are more data or even more errors, we can't read them
                raise KustoMultiApiError([self.parse_object(skip_start=True)])
            if token.token_type == JsonTokenType.END_ARRAY:
                return
            yield self.parse_array(skip_start=True)