gstreamer/subprojects/gst-devtools/debug-viewer/GstDebugViewer/Common/Data.py

# -*- coding: utf-8; mode: python; -*-
#
#  GStreamer Development Utilities
#
#  Copyright (C) 2007 René Stadler <mail@renestadler.de>
#
#  This program is free software; you can redistribute it and/or modify it
#  under the terms of the GNU General Public License as published by the Free
#  Software Foundation; either version 3 of the License, or (at your option)
#  any later version.
#
#  This program is distributed in the hope that it will be useful, but WITHOUT
#  ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
#  FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
#  more details.
#
#  You should have received a copy of the GNU General Public License along with
#  this program.  If not, see <http://www.gnu.org/licenses/>.

"""GStreamer Development Utilities Common Data module."""

import gi

from gi.repository import GObject


class Dispatcher (object):

    def __call__(self, iterator):

        raise NotImplementedError("derived classes must override this method")

    def cancel(self):

        pass


class DefaultDispatcher (Dispatcher):

    def __call__(self, iterator):

        for x in iterator:
            pass


class GSourceDispatcher (Dispatcher):

    def __init__(self):

        Dispatcher.__init__(self)

        self.source_id = None

    def __call__(self, iterator):

        if self.source_id is not None:
            GObject.source_remove(self.source_id)

        def iteration():
            r = iterator.__next__()
            if not r:
                self.source_id = None
            return r

        self.source_id = GObject.idle_add(
            iteration, priority=GObject.PRIORITY_LOW)

    def cancel(self):

        if self.source_id is None:
            return

        GObject.source_remove(self.source_id)
        self.source_id = None