Compare commits

..

1 Commits

Author SHA1 Message Date
Kevin Jahns
88c71b9c1e v13.0.0-11 -- distribution files 2017-08-04 16:31:45 +02:00
6 changed files with 46 additions and 52 deletions

View File

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

View File

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

10
y.js

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

View File

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

File diff suppressed because one or more lines are too long