def push(self, data):
        """
        Push new data to stream
        """
        defers = []

        log.msg("Pushing data to peers=%s" % self.peers)
        
        for peer in self.peers:
            d = peer.callRemote('stream', self.formatter.encode(data), self.formatter)

            defers.append(d)
            
        if len(defers) > 1:
            return defer.DeferredList(defers)
        
        return defers.pop()
dataset/ETHPy150Open selfsk/nodeset.core/src/nodeset/core/stream.py/Stream.push/original