Function finishReplay

src/node/orpc/replayBufferedStreamMessageRelay.ts:159–177

()

  };

  const finishReplay = () => {
    // Flush buffered live session messages after replay (`caught-up` already queued by replayHistory).
    for (const message of bufferedLiveSessionMessages) {
      if (isReplayBufferedDeltaMessage(message) && shouldDropBufferedDelta(message)) {
        continue;
      }
      if (isReplayBufferedInitMessage(message) && shouldDropBufferedInit(message)) {
        continue;
      }
      push(message);
    }

    isReplaying = false;

    // Avoid retaining replay keys for the lifetime of the subscription.
    replayedDeltaKeyCounts.clear();
    replayedInitKeyCounts.clear();
    bufferedLiveSessionMessages.length = 0;
  };

  return { handleSessionMessage, finishReplay };
}