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

        Can be overriden in subclasses to handle more.
        """
        self.store.process_replication_rows(stream_name, token, [])
Called when we get new position data. By default this just pokes
        the slave store.

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

Can be overriden in subclasses to handle more.
Called when we get new position data . By default this just pokes the slave store . Can be overriden in subclasses to handle more .
def on_position(self, stream_name, token):
        self.store.process_replication_rows(stream_name, token, [])
def on_position ( self , stream_name , token ) : self . store . process_replication_rows ( stream_name , token , [ ] )
Called when we get new position data.
Called when we get new position data .
"""Called when we get new position data. By default this just pokes
        the slave store.

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