39efccc696a1c20745a52cc50935cdc24f92230d,secuml/core/classif/classifiers/__init__.py,Classifier,_predict_streaming,#Classifier#,146

Before Change

            ids.append(instance_id)
            row = next(features_iter)
            num_rows += 1
            if matrix is None:
                matrix = [row]
            else:
                matrix = np.vstack((matrix, row))
            if num_rows >= stream_batch:
                ids = instances_ids.get_from_ids(ids)
                predictions = self._update_streaming_predictions(predictions,
                                                                 matrix, ids)

After Change

            predictions = self._update_streaming_predictions(predictions,
                                                             matrix, ids)
        if num_remaining > 0:
            matrix = np.vstack(tuple(next(features_iter)
                                     for _ in range(num_remaining)))
            ids = instances_ids.ids[-num_remaining:]
            ids = instances_ids.get_from_ids(ids)
            predictions = self._update_streaming_predictions(predictions,
                                                             matrix, ids)

Instances