Method _process_iterator

modelscope/pipelines/base.py:265–267

(self, input: Input, *args, **kwargs)

        return {}, {}, pipeline_parameters

    def _process_iterator(self, input: Input, *args, **kwargs):
        for ele in input:
            yield self._process_single(ele, *args, **kwargs)

    def _collate_fn(self, data):
        return collate_fn(data, self.device)