v13.0.0-12 -- distribution files

package.json

@@ -1,6 +1,6 @@
 {
   "name": "yjs",
-  "version": "13.0.0-11",
+  "version": "13.0.0-12",
   "description": "A framework for real-time p2p shared editing on any data",
   "main": "./y.node.js",
   "browser": "./y.js",

src/MessageHandler.js

@@ -92,6 +92,7 @@ export function computeMessageSyncStep1 (decoder, encoder, conn, senderConn, sen
     conn.y.destroy()
   }
 
+  return conn.y.db.whenTransactionsFinished().then(() => {
     // send sync step 2
     conn.y.db.requestTransaction(function * () {
       encoder.writeVarString('sync step 2')
@@ -109,10 +110,12 @@ export function computeMessageSyncStep1 (decoder, encoder, conn, senderConn, sen
       conn.send(senderConn.uid, encoder.createBuffer())
       senderConn.receivedSyncStep2 = true
     })
+    return conn.y.db.whenTransactionsFinished().then(() => {
       if (conn.role === 'slave') {
         sendSyncStep1(conn, sender)
       }
-  return conn.y.db.whenTransactionsFinished()
+    })
+  })
 }
 
 export function logSS (decoder, strBuilder) {

y.node.js

@@ -1,7 +1,7 @@
 
 /**
  * yjs - A framework for real-time p2p shared editing on any data
- * @version v13.0.0-11
+ * @version v13.0.0-12
  * @license MIT
  */
 
@@ -506,6 +506,7 @@ function computeMessageSyncStep1 (decoder, encoder, conn, senderConn, sender) {
     conn.y.destroy();
   }
 
+  return conn.y.db.whenTransactionsFinished().then(() => {
     // send sync step 2
     conn.y.db.requestTransaction(function * () {
       encoder.writeVarString('sync step 2');
@@ -523,10 +524,12 @@ function computeMessageSyncStep1 (decoder, encoder, conn, senderConn, sender) {
       conn.send(senderConn.uid, encoder.createBuffer());
       senderConn.receivedSyncStep2 = true;
     });
+    return conn.y.db.whenTransactionsFinished().then(() => {
       if (conn.role === 'slave') {
         sendSyncStep1(conn, sender);
       }
-  return conn.y.db.whenTransactionsFinished()
+    })
+  })
 }
 
 function logSS (decoder, strBuilder) {