yonote/yjs
19
0
Fork 0
Code Pull Requests 1 Releases Activity

catch y-* related errors

Browse Source
This commit is contained in:
Kevin Jahns 2017-09-20 11:29:13 +02:00
parent f537a43e29
commit 40fb16ef32
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Utils.js
View File

@ -67,7 +67,11 @@ export default function Utils (Y) {
this._eventListener[name] = listener.filter(e => e !== f) this._eventListener[name] = listener.filter(e => e !== f)
} }
emit (name, value) { emit (name, value) {
(this._eventListener[name] || []).forEach(l => l(value)) let listener = this._eventListener[name] || []
if (name === 'error' && listener.length === 0) {
console.error(value)
}
listener.forEach(l => l(value))
} }
destroy () { destroy () {
this._eventListener = null this._eventListener = null

11
src/y-memory.js
View File

@ -1,4 +1,3 @@
import extendRBTree from './RedBlackTree' import extendRBTree from './RedBlackTree'
export default function extend (Y) { export default function extend (Y) {
@ -48,9 +47,13 @@ export default function extend (Y) {
} }
transact (makeGen) { transact (makeGen) {
const t = new Transaction(this) const t = new Transaction(this)
while (makeGen != null) { try {
makeGen.call(t) while (makeGen != null) {
makeGen = this.getNextRequest() makeGen.call(t)
makeGen = this.getNextRequest()
}
} catch (e) {
this.y.emit('error', e)
} }
} }
destroy () { destroy () {