This commit is contained in:
Kevin Jahns 2021-02-14 15:44:47 +01:00
parent 88cff979f5
commit 02f691d89c

View File

@ -156,8 +156,7 @@ const setupWS = provider => {
*/ */
const broadcastMessage = (provider, buf) => { const broadcastMessage = (provider, buf) => {
if (provider.wsconnected) { if (provider.wsconnected) {
// @ts-ignore We know that wsconnected = true /** @type {WebSocket} */ (provider.ws).send(buf)
provider.ws.send(buf)
} }
if (provider.bcconnected) { if (provider.bcconnected) {
provider.mux(() => { provider.mux(() => {
@ -258,7 +257,7 @@ export class WebsocketProvider extends Observable {
* @param {any} origin * @param {any} origin
*/ */
this._updateHandler = (update, origin) => { this._updateHandler = (update, origin) => {
if (origin !== this || origin === null) { if (origin !== this) {
const encoder = encoding.createEncoder() const encoder = encoding.createEncoder()
encoding.writeVarUint(encoder, messageSync) encoding.writeVarUint(encoder, messageSync)
syncProtocol.writeUpdate(encoder, update) syncProtocol.writeUpdate(encoder, update)