code: def stream(q, format, option, src, segment_length, sample_rate):
      print("Building StreamReader...")
      streamer = torchaudio.io.StreamReader(
          src=src, format=format, option=option
      )
      streamer.add_basic_video_stream(
          frames_per_chunk=segment_length,
          buffer_chunk_size=500,
          width=600,
          height=340,
      )
      streamer.add_basic_audio_stream(
          frames_per_chunk=segment_length * 640, sample_rate=sample_rate
      )
  
      print(streamer.get_src_stream_info(0))
      print(streamer.get_src_stream_info(1))
      print("Streaming...")
      print()
      for chunk_v, chunk_a in streamer.stream(timeout=-1, backoff=1.0):
          q.put([chunk_v, chunk_a])
  
imports: import numpy
  import sentencepiece
  import torch
  import torchaudio
  import torchvision
  import sys
  from avsr.data_prep.detectors.mediapipe.detector import LandmarksDetector
  from avsr.data_prep.detectors.mediapipe.video_process import VideoProcess
  from torchaudio.utils import download_asset
label_desc: Use image node_id 1 for calling a global function with example usage: stream(q, format, option, src, segment_length, sample_rate) without return types