(self, asynchronous)
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_asynchronous(self, asynchronous):
        """
        Percolate information about an event loop to the rest of the stream
        """
        if self.asynchronous is not None:
            if self.asynchronous is not asynchronous:
                raise ValueError("Stream has both asynchronous and synchronous elements")
        else:
            self.asynchronous = asynchronous
            for upstream in self.upstreams:
                if upstream:
                    upstream._inform_asynchronous(asynchronous)
            for downstream in self.downstreams:
                if downstream:
                    downstream._inform_asynchronous(asynchronous)
def _inform_asynchronous ( self , asynchronous ) : if self . asynchronous is not None : if self . asynchronous is not asynchronous : raise ValueError ( "Stream has both asynchronous and synchronous elements" ) else : self . asynchronous = asynchronous for upstream in self . upstreams : if upstream : upstream . _inform_asynchronous ( asynchronous ) for downstream in self . downstreams : if downstream : downstream . _inform_asynchronous ( asynchronous )