(self, loop)
Percolate information about an event loop to the rest of the stream
Percolate information about an event loop to the rest of the stream
Percolate information about an event loop to the rest of the stream
def _inform_loop(self, loop):
        """
        Percolate information about an event loop to the rest of the stream
        """
        if self.loop is not None:
            if self.loop is not loop:
                raise ValueError("Two different event loops active")
        else:
            self.loop = loop
            for upstream in self.upstreams:
                if upstream:
                    upstream._inform_loop(loop)
            for downstream in self.downstreams:
                if downstream:
                    downstream._inform_loop(loop)
def _inform_loop ( self , loop ) : if self . loop is not None : if self . loop is not loop : raise ValueError ( "Two different event loops active" ) else : self . loop = loop for upstream in self . upstreams : if upstream : upstream . _inform_loop ( loop ) for downstream in self . downstreams : if downstream : downstream . _inform_loop ( loop )