code: def get_stream_chunk(self):
      if self.streaming:
          chunk = self._streaming_queue.get(block=True)
          if chunk == Gst.MessageType.EOS:
              return None
          else:
              self._streaming_queue.task_done()
              return chunk
  
      else:
          raise TypeError("function only available in streaming mode")
  
file_path: TimeSide/timeside/core/encoder.py
imports: from timeside.core import Processor, implements, interfacedoc, abstract
  from timeside.core.api import IEncoder
  from .tools.gstutils import numpy_array_to_gst_buffer, MainloopThread
  import gi
  from gi.repository import GLib, Gst
  import threading
label_desc: Use image node_id 10 for calling the GstEncoder obj's underlying member method code with example usage: obj.get_stream_chunk() and returns: None, chunk