Function shouldDropBufferedInit

src/node/orpc/replayBufferedStreamMessageRelay.ts:124–136

(message: ReplayBufferedInitMessage)

  };

  const shouldDropBufferedInit = (message: ReplayBufferedInitMessage): boolean => {
    const key = replayBufferedInitKey(message);
    const remaining = replayedInitKeyCounts.get(key) ?? 0;
    if (remaining <= 0) {
      return false;
    }
    if (remaining === 1) {
      replayedInitKeyCounts.delete(key);
    } else {
      replayedInitKeyCounts.set(key, remaining - 1);
    }
    return true;
  };

  const handleSessionMessage = (message: WorkspaceChatMessage) => {
    if (isReplaying && isReplayBufferedSessionMessage(message)) {