Function noteReplayedInit

src/node/orpc/replayBufferedStreamMessageRelay.ts:105–108

(message: ReplayBufferedInitMessage)

  };

  const noteReplayedInit = (message: ReplayBufferedInitMessage) => {
    const key = replayBufferedInitKey(message);
    replayedInitKeyCounts.set(key, (replayedInitKeyCounts.get(key) ?? 0) + 1);
  };

  const shouldDropBufferedDelta = (message: ReplayBufferedDeltaMessage): boolean => {
    const key = replayBufferedDeltaKey(message);