Compare commits
2 Commits
v13.0.0-75
...
v13.0.0-76
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4063e28b5e | ||
|
|
b6f7cd7869 |
2
package-lock.json
generated
2
package-lock.json
generated
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "yjs",
|
||||
"version": "13.0.0-75",
|
||||
"version": "13.0.0-76",
|
||||
"lockfileVersion": 1,
|
||||
"requires": true,
|
||||
"dependencies": {
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "yjs",
|
||||
"version": "13.0.0-75",
|
||||
"version": "13.0.0-76",
|
||||
"description": "A ",
|
||||
"main": "./build/yjs.js",
|
||||
"module": "./index.js'",
|
||||
@@ -18,6 +18,7 @@
|
||||
"now-start": "npm run websocket-server"
|
||||
},
|
||||
"files": [
|
||||
"build/*",
|
||||
"bindings/*",
|
||||
"docs/*",
|
||||
"examples/*",
|
||||
|
||||
@@ -104,8 +104,8 @@ class WebsocketsSharedDocument extends Y.Y {
|
||||
setupWS(this, url)
|
||||
this.on('afterTransaction', broadcastUpdate)
|
||||
this._bcSubscriber = data => {
|
||||
const encoder = readMessage(this, data) // already muxed
|
||||
this.mux(() => {
|
||||
const encoder = readMessage(this, data)
|
||||
if (Y.encoding.length(encoder) > 1) {
|
||||
bc.publish(url, Y.encoding.toBuffer(encoder))
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user