emit transaction on update call
This commit is contained in:
parent
e19f16f22c
commit
c28ad0608e
@ -340,14 +340,14 @@ const cleanupTransactions = (transactionCleanups, i) => {
|
|||||||
const encoder = new DefaultUpdateEncoder()
|
const encoder = new DefaultUpdateEncoder()
|
||||||
const hasContent = writeUpdateMessageFromTransaction(encoder, transaction)
|
const hasContent = writeUpdateMessageFromTransaction(encoder, transaction)
|
||||||
if (hasContent) {
|
if (hasContent) {
|
||||||
doc.emit('update', [encoder.toUint8Array(), transaction.origin, doc])
|
doc.emit('update', [encoder.toUint8Array(), transaction.origin, doc, transaction])
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (doc._observers.has('updateV2')) {
|
if (doc._observers.has('updateV2')) {
|
||||||
const encoder = new UpdateEncoderV2()
|
const encoder = new UpdateEncoderV2()
|
||||||
const hasContent = writeUpdateMessageFromTransaction(encoder, transaction)
|
const hasContent = writeUpdateMessageFromTransaction(encoder, transaction)
|
||||||
if (hasContent) {
|
if (hasContent) {
|
||||||
doc.emit('updateV2', [encoder.toUint8Array(), transaction.origin, doc])
|
doc.emit('updateV2', [encoder.toUint8Array(), transaction.origin, doc, transaction])
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
transaction.subdocsAdded.forEach(subdoc => doc.subdocs.add(subdoc))
|
transaction.subdocsAdded.forEach(subdoc => doc.subdocs.add(subdoc))
|
||||||
|
Loading…
x
Reference in New Issue
Block a user