synapse/replication/tcp/client.py
def on_rdata(self, stream_name, token, rows):
        """Called when we get new replication data. By default this just pokes
        the slave store.

        Can be overriden in subclasses to handle more.
        """
        logger.info("Received rdata %s -> %s", stream_name, token)
        self.store.process_replication_rows(stream_name, token, rows)
Called when we get new replication data. By default this just pokes
        the slave store.

        Can be overriden in subclasses to handle more.
        
Called when we get new replication data. By default this just pokes
the slave store.

Can be overriden in subclasses to handle more.
Called when we get new replication data . By default this just pokes the slave store . Can be overriden in subclasses to handle more .
def on_rdata(self, stream_name, token, rows):
        logger.info("Received rdata %s -> %s", stream_name, token)
        self.store.process_replication_rows(stream_name, token, rows)
def on_rdata ( self , stream_name , token , rows ) : logger . info ( "Received rdata %s -> %s" , stream_name , token ) self . store . process_replication_rows ( stream_name , token , rows )
Called when we get new replication data.
Called when we get new replication data .
"""Called when we get new replication data. By default this just pokes
        the slave store.

        Can be overriden in subclasses to handle more.
        """
self
stream_name
token
rows