?HAMA

Edit File Size: 3.17 KB

/proc/thread-self/root/home/byroehnu/.trash/node_modules11/react-redux/lib/utils/Subscription.js

Text Base64

"use strict";

exports.__esModule = true;
exports.createSubscription = createSubscription;

var _batch = require("./batch");

function createListenerCollection() {
  const batch = (0, _batch.getBatch)();
  let first = null;
  let last = null;
  return {
    clear() {
      first = null;
      last = null;
    },

notify() {
      batch(() => {
        let listener = first;

while (listener) {
          listener.callback();
          listener = listener.next;
        }
      });
    },

get() {
      let listeners = [];
      let listener = first;

while (listener) {
        listeners.push(listener);
        listener = listener.next;
      }

return listeners;
    },

subscribe(callback) {
      let isSubscribed = true;
      let listener = last = {
        callback,
        next: null,
        prev: last
      };

if (listener.prev) {
        listener.prev.next = listener;
      } else {
        first = listener;
      }

return function unsubscribe() {
        if (!isSubscribed || first === null) return;
        isSubscribed = false;

if (listener.next) {
          listener.next.prev = listener.prev;
        } else {
          last = listener.prev;
        }

if (listener.prev) {
          listener.prev.next = listener.next;
        } else {
          first = listener.next;
        }
      };
    }

};
}

const nullListeners = {
  notify() {},

get: () => []
};

function createSubscription(store, parentSub) {
  let unsubscribe;
  let listeners = nullListeners; // Reasons to keep the subscription active

let subscriptionsAmount = 0; // Is this specific subscription subscribed (or only nested ones?)

let selfSubscribed = false;

function addNestedSub(listener) {
    trySubscribe();
    const cleanupListener = listeners.subscribe(listener); // cleanup nested sub

let removed = false;
    return () => {
      if (!removed) {
        removed = true;
        cleanupListener();
        tryUnsubscribe();
      }
    };
  }

function notifyNestedSubs() {
    listeners.notify();
  }

function handleChangeWrapper() {
    if (subscription.onStateChange) {
      subscription.onStateChange();
    }
  }

function isSubscribed() {
    return selfSubscribed;
  }

function trySubscribe() {
    subscriptionsAmount++;

if (!unsubscribe) {
      unsubscribe = parentSub ? parentSub.addNestedSub(handleChangeWrapper) : store.subscribe(handleChangeWrapper);
      listeners = createListenerCollection();
    }
  }

function tryUnsubscribe() {
    subscriptionsAmount--;

if (unsubscribe && subscriptionsAmount === 0) {
      unsubscribe();
      unsubscribe = undefined;
      listeners.clear();
      listeners = nullListeners;
    }
  }

function trySubscribeSelf() {
    if (!selfSubscribed) {
      selfSubscribed = true;
      trySubscribe();
    }
  }

function tryUnsubscribeSelf() {
    if (selfSubscribed) {
      selfSubscribed = false;
      tryUnsubscribe();
    }
  }

const subscription = {
    addNestedSub,
    notifyNestedSubs,
    handleChangeWrapper,
    isSubscribed,
    trySubscribe: trySubscribeSelf,
    tryUnsubscribe: tryUnsubscribeSelf,
    getListeners: () => listeners
  };
  return subscription;
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
batch.js	495 B	lrw-r--r--	2026-02-28 00:27:26	Edit Download recursive recursive
bindActionCreators.js	427 B	lrw-r--r--	2026-02-28 00:27:38	Edit Download recursive recursive
isPlainObject.js	537 B	lrw-r--r--	2026-02-28 00:28:32	Edit Download recursive recursive
reactBatchedUpdates.js	235 B	lrw-r--r--	2026-02-28 00:28:58	Edit Download recursive recursive
reactBatchedUpdates.native.js	244 B	lrw-r--r--	2026-02-28 00:29:00	Edit Download recursive recursive
shallowEqual.js	718 B	lrw-r--r--	2026-02-28 00:29:06	Edit Download recursive recursive
Subscription.js	3.17 KB	lrw-r--r--	2026-02-28 00:29:06	Edit Download recursive recursive
useIsomorphicLayoutEffect.js	2.24 KB	lrw-r--r--	2026-02-28 00:29:10	Edit Download recursive recursive
useIsomorphicLayoutEffect.native.js	1.42 KB	lrw-r--r--	2026-02-28 00:29:12	Edit Download recursive recursive
useSyncExternalStore.js	195 B	lrw-r--r--	2026-02-28 00:29:22	Edit Download recursive recursive
verifyPlainObject.js	533 B	lrw-r--r--	2026-02-28 00:29:30	Edit Download recursive recursive
warning.js	700 B	lrw-r--r--	2026-02-28 00:29:34	Edit Download recursive recursive

Directory Contents