code: def _check_episode(self, stream):
      timestep = stream.reset()
      self.assertIsNotNone(timestep)
  
      while True:
          timestep = stream.step(_action(random.randint(1, 5)))
          if timestep.step_type == dm_env.StepType.LAST:
              break
      self.assertIsNotNone(timestep)
  
imports: import concurrent.futures
  import random
  from absl.testing import absltest
  import dm_env
  from dm_env import test_utils
  import numpy
  from pysc2.env import converted_env
  from pysc2.env import mock_sc2_env
  from pysc2.env import sc2_env
  from pysc2.env.converter import converter
  from pysc2.env.converter.proto import converter_pb2
  from pysc2.lib import features
  from s2clientprotocol import common_pb2
  from s2clientprotocol import sc2api_pb2
label_desc: Use image node_id 1 for calling the StreamedEnvTest obj's underlying member method code with example usage: obj._check_episode(stream) without return types