Function updateSubDocHandler

packages/yjs-websocket/src/server/utils.ts:41–53

(
  subId: string,
  update: Uint8Array,
  origin: string,
  doc: WSSharedDocInterface,
)

}

const updateSubDocHandler = (
  subId: string,
  update: Uint8Array,
  origin: string,
  doc: WSSharedDocInterface,
) => {
  const encoder = encoding.createEncoder()
  encoding.writeVarUint(encoder, messageSubDocSync)
  encoding.writeVarString(encoder, subId)
  syncProtocol.writeUpdate(encoder, update)
  const message = encoding.toUint8Array(encoder)
  doc.conns.forEach((_, conn) => send(doc, conn, message))
}

interface AwarenessChangeHandlerOptions {
  added: number[]