Function createPayloadReceiver

src/synchronizers/common.ts:60–109

(
  receive: Receive,
  fragmentTimeoutSeconds: number = 1,
)

  );

export const createPayloadReceiver = (
  receive: Receive,
  fragmentTimeoutSeconds: number = 1,
) => {
  const buffer: IdMap<Pending> = mapNew();

  const setPendingTimeout = (bufferKey: Id) =>
    startTimeout(() => collDel(buffer, bufferKey), fragmentTimeoutSeconds);

  const delPending = (bufferKey: Id, pending: Pending) => {
    stopTimeout(pending[3]);
    collDel(buffer, bufferKey);
  };

  return (payload: string) =>
    ifPayloadValid(payload, (fromClientId, remainder) => {
      const [, messageId, indexStr, totalStr, fragment] =
        strMatch(remainder, FRAGMENT) ?? [];
      if (messageId) {
        const index = parseInt(indexStr);
        const total = parseInt(totalStr);
        if (total > 0 && index >= 0 && index < total) {
          const bufferKey = fromClientId + MESSAGE_SEPARATOR + messageId;
          const pending = mapEnsure(buffer, bufferKey, (): Pending => [
            [],
            total,
            total,
            setPendingTimeout(bufferKey),
          ]);
          const [fragments] = pending;
          if (total == pending[2] && isUndefined(fragments[index])) {
            stopTimeout(pending[3]);
            pending[3] = setPendingTimeout(bufferKey);
            fragments[index] = fragment;
            pending[1]--;
          }
          if (pending[1] == 0) {
            delPending(bufferKey, pending);
            receivePayloadRemainder(
              fromClientId,
              arrayJoin(fragments),
              receive,
            );
          }
        }
      } else {
        receivePayloadRemainder(fromClientId, remainder, receive);
      }
    });
};

export const createPayload = (
  toClientId: IdOrNull,