RocketChat/Rocket.Chat

Function createReactiveSubscriptionFactory has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    (...args: any[]): [subscribe: (onStoreChange: () => void) => () => void, getSnapshot: () => T] => {
        const callbacks = new Set<() => void>();

        let currentValue = computeCurrentValueWith(...args);