INIT
CI / build (push) Has been skipped
CI / deploy (push) Successful in 1m11s

This commit is contained in:
eewing
2026-02-18 15:17:47 -06:00
parent e74c106f85
commit ec317eb17c
11532 changed files with 1631690 additions and 1 deletions
+1
View File
@@ -0,0 +1 @@
export * from "./watch.svelte.js";
+1
View File
@@ -0,0 +1 @@
export * from "./watch.svelte.js";
+36
View File
@@ -0,0 +1,36 @@
import type { Getter } from "../../internal/types.js";
export type WatchOptions = {
/**
* If `true`, the effect doesn't run until one of the `sources` changes.
*
* @default false
*/
lazy?: boolean;
};
export declare function watch<T extends Array<unknown>>(sources: {
[K in keyof T]: Getter<T[K]>;
}, effect: (values: T, previousValues: {
[K in keyof T]: T[K] | undefined;
}) => void | VoidFunction, options?: WatchOptions): void;
export declare function watch<T>(source: Getter<T>, effect: (value: T, previousValue: T | undefined) => void | VoidFunction, options?: WatchOptions): void;
export declare namespace watch {
var pre: typeof watchPre;
}
declare function watchPre<T extends Array<unknown>>(sources: {
[K in keyof T]: Getter<T[K]>;
}, effect: (values: T, previousValues: {
[K in keyof T]: T[K] | undefined;
}) => void | VoidFunction, options?: WatchOptions): void;
declare function watchPre<T>(source: Getter<T>, effect: (value: T, previousValue: T | undefined) => void | VoidFunction, options?: WatchOptions): void;
export declare function watchOnce<T extends Array<unknown>>(sources: {
[K in keyof T]: Getter<T[K]>;
}, effect: (values: T, previousValues: T) => void | VoidFunction): void;
export declare function watchOnce<T>(source: Getter<T>, effect: (value: T, previousValue: T) => void | VoidFunction): void;
export declare namespace watchOnce {
var pre: typeof watchOncePre;
}
declare function watchOncePre<T extends Array<unknown>>(sources: {
[K in keyof T]: Getter<T[K]>;
}, effect: (values: T, previousValues: T) => void | VoidFunction): void;
declare function watchOncePre<T>(source: Getter<T>, effect: (value: T, previousValue: T) => void | VoidFunction): void;
export {};
+69
View File
@@ -0,0 +1,69 @@
import { untrack } from "svelte";
function runEffect(flush, effect) {
switch (flush) {
case "post":
$effect(effect);
break;
case "pre":
$effect.pre(effect);
break;
}
}
function runWatcher(sources, flush, effect, options = {}) {
const { lazy = false } = options;
// Run the effect immediately if `lazy` is `false`.
let active = !lazy;
// On the first run, if the dependencies are an array, pass an empty array
// to the previous value instead of `undefined` to allow destructuring.
//
// watch(() => [a, b], ([a, b], [prevA, prevB]) => { ... });
let previousValues = Array.isArray(sources)
? []
: undefined;
runEffect(flush, () => {
const values = Array.isArray(sources) ? sources.map((source) => source()) : sources();
if (!active) {
active = true;
previousValues = values;
return;
}
const cleanup = untrack(() => effect(values, previousValues));
previousValues = values;
return cleanup;
});
}
function runWatcherOnce(sources, flush, effect) {
const cleanupRoot = $effect.root(() => {
let stop = false;
runWatcher(sources, flush, (values, previousValues) => {
if (stop) {
cleanupRoot();
return;
}
// Since `lazy` is `true`, `previousValues` is always defined.
const cleanup = effect(values, previousValues);
stop = true;
return cleanup;
},
// Running the effect immediately just once makes no sense at all.
// That's just `onMount` with extra steps.
{ lazy: true });
});
$effect(() => {
return cleanupRoot;
});
}
export function watch(sources, effect, options) {
runWatcher(sources, "post", effect, options);
}
function watchPre(sources, effect, options) {
runWatcher(sources, "pre", effect, options);
}
watch.pre = watchPre;
export function watchOnce(source, effect) {
runWatcherOnce(source, "post", effect);
}
function watchOncePre(source, effect) {
runWatcherOnce(source, "pre", effect);
}
watchOnce.pre = watchOncePre;