Function noteReplayedDelta

src/node/orpc/replayBufferedStreamMessageRelay.ts:100–103

(message: ReplayBufferedDeltaMessage)

  const replayedInitKeyCounts = new Map<string, number>();

  const noteReplayedDelta = (message: ReplayBufferedDeltaMessage) => {
    const key = replayBufferedDeltaKey(message);
    replayedDeltaKeyCounts.set(key, (replayedDeltaKeyCounts.get(key) ?? 0) + 1);
  };

  const noteReplayedInit = (message: ReplayBufferedInitMessage) => {
    const key = replayBufferedInitKey(message);