# Path: video_processing/stream_processor.py
# class Frame(collections.namedtuple('FrameSet', ['index', 'data'])):
# class StreamSet(collections.namedtuple('StreamSet', ['frame_rate_hz',
#                                                      'stream_headers'])):
# class ProcessorBase(object):
#   def __new__(cls, index=0, data=None):
#   def __new__(cls, frame_rate_hz=-1):
#   def __init__(self, configuration):
#   def open(self, stream_set):
#   def process(self, frame_set):
#   def close(self):


from video_processing import stream_processor
# Copyright 2019 Google LLC.
"""Utility function for running a chain of processors."""

from __future__ import absolute_import
from __future__ import division
from __future__ import print_function



def run_processor_chain(processors_list):
  """Runs a chain of processors.

  Runs a chain of processors defined by processors_list.

  Args:
    processors_list: A list of instances of subclasses of
        stream_processor.ProcessorBase.
  """

# Path: video_processing/stream_processor.py
# class Frame(collections.namedtuple('FrameSet', ['index', 'data'])):
# class StreamSet(collections.namedtuple('StreamSet', ['frame_rate_hz',
#                                                      'stream_headers'])):
# class ProcessorBase(object):
#   def __new__(cls, index=0, data=None):
#   def __new__(cls, frame_rate_hz=-1):
#   def __init__(self, configuration):
#   def open(self, stream_set):
#   def process(self, frame_set):
#   def close(self):


# Path: video_processing/processor_runner.py
from video_processing import stream_processor

# Copyright 2019 Google LLC.
"""Utility function for running a chain of processors."""

from __future__ import absolute_import
from __future__ import division
from __future__ import print_function



def run_processor_chain(processors_list):
  """Runs a chain of processors.

  Runs a chain of processors defined by processors_list.

  Args:
    processors_list: A list of instances of subclasses of
        stream_processor.ProcessorBase.
  """

  streams = stream_processor.StreamSet()