code: def video_streamer(path, frames_per_chunk):
      import queue
      import threading
  
      from torchaudio.io import StreamReader
  
      q = queue.Queue()
  
      # Streaming process that runs in background thread
      def _streamer():
          streamer = StreamReader(path)
          streamer.add_basic_video_stream(
              frames_per_chunk,
              format="rgb24",
              frame_rate=frame_rate,
              width=width,
              height=height,
          )
          for (chunk_,) in streamer.stream():
              q.put(chunk_)
              if not running:
                  break
  
      # Start the background thread and fetch chunks
      t = threading.Thread(target=_streamer)
      t.start()
      while running:
          try:
              yield q.get()
          except queue.Empty:
              break
      t.join()
  
imports: import torch
  import torchaudio
  from torchaudio.io import StreamWriter
  from torchaudio.utils import download_asset
label_desc: Use image node_id 1 for calling a global function with example usage: video_streamer(path, frames_per_chunk) without return types