Function createCustomLocalSynchronizer

test/unit/persisters/common/mocks.ts:417–450

(
  store: MergeableStore,
  clients: Map<string, Receive>,
)

};

const createCustomLocalSynchronizer = (
  store: MergeableStore,
  clients: Map<string, Receive>,
): Synchronizer => {
  const clientId = 'client' + clients.size;
  return createCustomSynchronizer(
    store,
    (toClientId, requestId, messageType, messageBody): void => {
      setTimeout(() => {
        if (toClientId == null) {
          clients.forEach((receive, otherClientId) =>
            otherClientId != clientId
              ? receive(clientId, requestId, messageType, messageBody)
              : 0,
          );
        } else {
          clients.get(toClientId)?.(
            clientId,
            requestId,
            messageType,
            messageBody,
          );
        }
      }, 0);
    },
    (receive: Receive): void => {
      clients.set(clientId, receive);
    },
    (): void => {
      clients.delete(clientId);
    },
    0.005,
  );
};

export const mockCustomSynchronizer: Persistable<
  [Map<string, Receive>, Synchronizer, MergeableStore]