msb-public
/
svelte
mirror of https://github.com/sveltejs/svelte
1
0
Code Issues Projects Releases Wiki Activity

Lint and format src/runtime/store/index.js

Browse Source
pull/8569/head
S. Elliott Johnson 3 years ago
parent 4e74b7de3c
commit efec4ef130
1 changed files with 141 additions and 132 deletions
Show Stats Download Patch File Download Diff File

273
src/runtime/store/index.js
Unescape View File

@ -1,4 +1,11 @@
import { run_all, subscribe, noop, safe_not_equal, is_function, get_store_value } from '../internal'; import {
run_all,
subscribe,
noop,
safe_not_equal,
is_function,
get_store_value
} from '../internal';
const subscriber_queue = []; const subscriber_queue = [];
/** /**
* Creates a `Readable` store that allows reading by subscription. * Creates a `Readable` store that allows reading by subscription.
@ -7,9 +14,9 @@ const subscriber_queue = [];
* @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Readable<T>} * @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Readable<T>}
*/ */
export function readable(value, start) { export function readable(value, start) {
return { return {
subscribe: writable(value, start).subscribe subscribe: writable(value, start).subscribe
}; };
} }
/** /**
* Create a `Writable` store that allows both updating and reading by subscription. * Create a `Writable` store that allows both updating and reading by subscription.
@ -18,59 +25,59 @@ export function readable(value, start) {
* @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Writable<T>} * @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Writable<T>}
*/ */
export function writable(value, start = noop) { export function writable(value, start = noop) {
/** @type {Unsubscriber} */ /** @type {Unsubscriber} */
let stop; let stop;
/** @type {Set<SubscribeInvalidateTuple<T>>} */ /** @type {Set<SubscribeInvalidateTuple<T>>} */
const subscribers = new Set(); const subscribers = new Set();
/** @param {T} new_value /** @param {T} new_value
* @returns {void} * @returns {void}
*/ */
function set(new_value) { function set(new_value) {
if (safe_not_equal(value, new_value)) { if (safe_not_equal(value, new_value)) {
value = new_value; value = new_value;
if (stop) { if (stop) {
// store is ready // store is ready
const run_queue = !subscriber_queue.length; const run_queue = !subscriber_queue.length;
for (const subscriber of subscribers) { for (const subscriber of subscribers) {
subscriber[1](); subscriber[1]();
subscriber_queue.push(subscriber, value); subscriber_queue.push(subscriber, value);
} }
if (run_queue) { if (run_queue) {
for (let i = 0; i < subscriber_queue.length; i += 2) { for (let i = 0; i < subscriber_queue.length; i += 2) {
subscriber_queue[i][0](subscriber_queue[i + 1]); subscriber_queue[i][0](subscriber_queue[i + 1]);
} }
subscriber_queue.length = 0; subscriber_queue.length = 0;
} }
} }
} }
} }
/** @param {Updater<T>} fn /** @param {Updater<T>} fn
* @returns {void} * @returns {void}
*/ */
function update(fn) { function update(fn) {
set(fn(value)); set(fn(value));
} }
/** @param {Subscriber<T>} run /** @param {Subscriber<T>} run
* @param {Invalidator<T>} invalidate * @param {Invalidator<T>} invalidate
* @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Unsubscriber} * @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Unsubscriber}
*/ */
function subscribe(run, invalidate = noop) { function subscribe(run, invalidate = noop) {
/** @type {SubscribeInvalidateTuple<T>} */ /** @type {SubscribeInvalidateTuple<T>} */
const subscriber = [run, invalidate]; const subscriber = [run, invalidate];
subscribers.add(subscriber); subscribers.add(subscriber);
if (subscribers.size === 1) { if (subscribers.size === 1) {
stop = start(set, update) || noop; stop = start(set, update) || noop;
} }
run(value); run(value);
return () => { return () => {
subscribers.delete(subscriber); subscribers.delete(subscriber);
if (subscribers.size === 0 && stop) { if (subscribers.size === 0 && stop) {
stop(); stop();
stop = null; stop = null;
} }
}; };
} }
return { set, update, subscribe }; return { set, update, subscribe };
} }
/** @param {Stores} stores /** @param {Stores} stores
* @param {Function} fn * @param {Function} fn
@ -78,53 +85,56 @@ export function writable(value, start = noop) {
* @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Readable<T>} * @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Readable<T>}
*/ */
export function derived(stores, fn, initial_value) { export function derived(stores, fn, initial_value) {
const single = !Array.isArray(stores); const single = !Array.isArray(stores);
/** @type {Array<Readable<any>>} */ /** @type {Array<Readable<any>>} */
const stores_array = single const stores_array = single ? [stores] : stores;
? [stores] if (!stores_array.every(Boolean)) {
: stores; throw new Error('derived() expects stores as input, got a falsy value');
if (!stores_array.every(Boolean)) { }
throw new Error('derived() expects stores as input, got a falsy value'); const auto = fn.length < 2;
} return readable(initial_value, (set, update) => {
const auto = fn.length < 2; let started = false;
return readable(initial_value, (set, update) => { const values = [];
let started = false; let pending = 0;
const values = []; let cleanup = noop;
let pending = 0; const sync = () => {
let cleanup = noop; if (pending) {
const sync = () => { return;
if (pending) { }
return; cleanup();
} const result = fn(single ? values[0] : values, set, update);
cleanup(); if (auto) {
const result = fn(single ? values[0] : values, set, update); set(result);
if (auto) { } else {
set(result); cleanup = is_function(result) ? result : noop;
} }
else { };
cleanup = is_function(result) ? result : noop; const unsubscribers = stores_array.map((store, i) =>
} subscribe(
}; store,
const unsubscribers = stores_array.map((store, i) => subscribe(store, (value) => { (value) => {
values[i] = value; values[i] = value;
pending &= ~(1 << i); pending &= ~(1 << i);
if (started) { if (started) {
sync(); sync();
} }
}, () => { },
pending |= 1 << i; () => {
})); pending |= 1 << i;
started = true; }
sync(); )
return function stop() { );
run_all(unsubscribers); started = true;
cleanup(); sync();
// We need to set this to false because callbacks can still happen despite having unsubscribed: return function stop() {
// Callbacks might already be placed in the queue which doesn't know it should no longer run_all(unsubscribers);
// invoke this derived store. cleanup();
started = false; // We need to set this to false because callbacks can still happen despite having unsubscribed:
}; // Callbacks might already be placed in the queue which doesn't know it should no longer
}); // invoke this derived store.
started = false;
};
});
} }
/** /**
* Takes a store and returns a new one derived from the old one that is readable. * Takes a store and returns a new one derived from the old one that is readable.
@ -133,9 +143,9 @@ export function derived(stores, fn, initial_value) {
* @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Readable<T>} * @returns {import("/Users/elliottjohnson/dev/sveltejs/svelte/index.ts-to-jsdoc").Readable<T>}
*/ */
export function readonly(store) { export function readonly(store) {
return { return {
subscribe: store.subscribe.bind(store) subscribe: store.subscribe.bind(store)
}; };
} }
/** /**
* Get the current value from a store by subscribing and immediately unsubscribing. * Get the current value from a store by subscribing and immediately unsubscribing.
@ -143,38 +153,37 @@ export function readonly(store) {
*/ */
export { get_store_value as get }; export { get_store_value as get };
/** /**
* @typedef {(value: T) => void} Subscriber * @typedef {(value: T) => void} Subscriber
* @template T * @template T
*/ */
/** @typedef {() => void} Unsubscriber */ /** @typedef {() => void} Unsubscriber */
/** /**
* @typedef {(value: T) => T} Updater * @typedef {(value: T) => T} Updater
* @template T * @template T
*/ */
/** /**
* @typedef {(value?: T) => void} Invalidator * @typedef {(value?: T) => void} Invalidator
* @template T * @template T
*/ */
/** /**
* @typedef {( * @typedef {(
* set: (value: T) => void, * set: (value: T) => void,
* update: (fn: Updater<T>) => void * update: (fn: Updater<T>) => void
* ) => void | (() => void)} StartStopNotifier * ) => void | (() => void)} StartStopNotifier
* @template T * @template T
*/ */
/** /**
* @typedef {[Subscriber<T>, Invalidator<T>]} SubscribeInvalidateTuple * @typedef {[Subscriber<T>, Invalidator<T>]} SubscribeInvalidateTuple
* @template T * @template T
*/ */
/** @typedef {Readable<any> | [Readable<any>, ...Array<Readable<any>>] | Array<Readable<any>>} Stores */ /** @typedef {Readable<any> | [Readable<any>, ...Array<Readable<any>>] | Array<Readable<any>>} Stores */
/** /**
* @typedef {T extends Readable<infer U> * @typedef {T extends Readable<infer U>
* ? U * ? U
* : { [K in keyof T]: T[K] extends Readable<infer U> ? U : never }} StoresValues * : { [K in keyof T]: T[K] extends Readable<infer U> ? U : never }} StoresValues
* @template T * @template T
*/ */
/** /**
* Readable interface for subscribing. * Readable interface for subscribing.
@ -183,4 +192,4 @@ export { get_store_value as get };
/** /**
* Writable interface for both updating and subscribing. * Writable interface for both updating and subscribing.
* @typedef {Object} Writable * @typedef {Object} Writable
*/ */

Write Preview
Loading…
Cancel
Save