Method schedulePartialWrite

src/node/services/streamManager.ts:731–753

* Write the current partial message to disk (throttled by mtime) * Ensures writes happen during rapid streaming (crash-resilient)

(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo
  )

   * Ensures writes happen during rapid streaming (crash-resilient)
   */
  private async schedulePartialWrite(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo
  ): Promise<void> {
    const now = Date.now();
    const timeSinceLastWrite = now - streamInfo.lastPartialWriteTime;

    // If enough time has passed, write immediately
    if (timeSinceLastWrite >= this.PARTIAL_WRITE_THROTTLE_MS) {
      await this.flushPartialWrite(workspaceId, streamInfo);
      return;
    }

    // Otherwise, schedule write for remaining time (fire-and-forget for scheduled writes)
    if (streamInfo.partialWriteTimer) {
      clearTimeout(streamInfo.partialWriteTimer);
    }

    const remainingTime = this.PARTIAL_WRITE_THROTTLE_MS - timeSinceLastWrite;
    streamInfo.partialWriteTimer = setTimeout(() => {
      void this.flushPartialWrite(workspaceId, streamInfo);
    }, remainingTime);
  }

  private async awaitPendingPartialWrite(streamInfo: WorkspaceStreamInfo): Promise<void> {
    if (streamInfo.partialWritePromise) {