diff --git a/src/Connector.js b/src/Connector.js index ed8d45c4..0cd54dc3 100644 --- a/src/Connector.js +++ b/src/Connector.js @@ -131,7 +131,9 @@ class AbstractConnector { f() } this.whenSyncedListeners = [] - this.y.db.garbageCollectAfterSync() + this.y.db.requestTransaction(function *() { + yield* this.store.garbageCollectAfterSync() + }) } } send (uid, message) { diff --git a/src/Helper.spec.js b/src/Helper.spec.js index 5fccccb7..84abc78a 100644 --- a/src/Helper.spec.js +++ b/src/Helper.spec.js @@ -268,16 +268,13 @@ function async (makeGenerator) { } g.async = async -var logUsers = async(function * logUsers (self) { +function logUsers (self) { if (self.constructor === Array) { self = {users: self} } - console.log('User 1: ', self.users[0].connector.userId, "=============================================") // eslint-disable-line - yield self.users[0].db.logTable() // eslint-disable-line - console.log('User 2: ', self.users[1].connector.userId, "=============================================") // eslint-disable-line - yield self.users[1].db.logTable() // eslint-disable-line - console.log('User 3: ', self.users[2].connector.userId, "=============================================") // eslint-disable-line - yield self.users[2].db.logTable() // eslint-disable-line -}) + self.users[0].db.logTable() + self.users[1].db.logTable() + self.users[2].db.logTable() +} g.logUsers = logUsers