Method init

packages/core/src/sync/room.ts:147–165

(firstRoomInit = false)

  }

  async init(firstRoomInit = false) {
    // Ensure that the collaborative engine has been initialized
    const hasCollaEngine = () => {
      return this.collaEngineMap.has(this.roomId);
    };
    do {
      await this.nextTick();
    } while (!hasCollaEngine());
    firstRoomInit && this.sendLocalChangesetWithInit();
    // Initialize the collaboration engine first
    await Promise.all(
      Array.from(this.collaEngineMap.keys()).map((resourceId) => {
        const collaEngine = this.collaEngineMap.get(resourceId)!;
        return collaEngine.waitPrepareComplete();
      })
    );

    await this.watch();
  }

  // When initializing, you need to send the locally cached localPendingChangeset (if any) to the server
  @errorCapture<RoomService>()