def _update_max_stream_id(self, txn, next_id):
        update_max_id_sql = (
            "UPDATE account_data_max_stream_id"
            " SET stream_id = ?"
            " WHERE stream_id < ?"
        )
        txn.execute(update_max_id_sql, (next_id, next_id))
Called when the connection is established with both parties.
dataset/ETHPy150Open matrix-org/synapse/synapse/storage/account_data.py/AccountDataStore._update_max_stream_id--crossover with--dataset/ETHPy150Open google/nogotofail/nogotofail/mitm/connection/handlers/base.py/BaseHandler.on_establish