def process_streamers(self):
        """Check if any streamers should be handed to the stream manager."""

        # Check for any triggered streamers and pass them to stream manager
        in_progress = self._stream_manager.in_progress()
        triggered = self.graph.check_streamers(blacklist=in_progress)

        for streamer in triggered:
            self._stream_manager.process_streamer(streamer, callback=self._handle_streamer_finished)
def process_streamers ( self ) : in_progress = self . _stream_manager . in_progress ( ) triggered = self . graph . check_streamers ( blacklist = in_progress ) for streamer in triggered : self . _stream_manager . process_streamer ( streamer , callback = self . _handle_streamer_finished )
Check if any streamers should be handed to the stream manager.