Function shouldDropBufferedDelta

src/node/orpc/replayBufferedStreamMessageRelay.ts:110–122

(message: ReplayBufferedDeltaMessage)

  };

  const shouldDropBufferedDelta = (message: ReplayBufferedDeltaMessage): boolean => {
    const key = replayBufferedDeltaKey(message);
    const remaining = replayedDeltaKeyCounts.get(key) ?? 0;
    if (remaining <= 0) {
      return false;
    }
    if (remaining === 1) {
      replayedDeltaKeyCounts.delete(key);
    } else {
      replayedDeltaKeyCounts.set(key, remaining - 1);
    }
    return true;
  };

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