code: def test_iterator_next_stopping(self, test_fn):
      strat, ds = _distributed_dataset()
      with self.assertRaises(tf.errors.OutOfRangeError):
          tf.function(test_fn)(strat, ds, tf.constant(True))
  
imports: import itertools
  from absl.testing import parameterized
  import tensorflow
  from tensorflow.python.autograph.tests import reference_test_base
label_desc: Use image node_id 5 for calling the ReferenceTest obj's underlying member method code with example usage: obj.test_iterator_next_stopping(test_fn) without return types