jaandrle/deka-dom-el
1
0
Fork 0
mirror of https://github.com/jaandrle/deka-dom-el synced 2025-04-01 19:55:53 +02:00
Code Packages Releases Activity

🐛 fixes #38

Browse Source
This commit is contained in:
Jan Andrle 2025-03-15 21:05:57 +01:00
parent 44c28f1bd2
commit df8095e1cb
Signed by: jaandrle
GPG Key ID: B3A25AED155AFFAB
7 changed files with 38 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
dist/esm-with-signals.js vendored
View File

@ -689,19 +689,19 @@ memo.scope = function memoScope(fun, { signal: signal2, onlyLast } = {}) {
// src/signals-lib/helpers.js
var mark = "__dde_signal";
var queueSignalWrite = /* @__PURE__ */ (() => {
let pendingSignals = /* @__PURE__ */ new Set();
let pendingSignals = /* @__PURE__ */ new Map();
let scheduled = false;
function flushSignals() {
scheduled = false;
const todo = pendingSignals;
pendingSignals = /* @__PURE__ */ new Set();
for (const signal2 of todo) {
pendingSignals = /* @__PURE__ */ new Map();
for (const [signal2, force] of todo) {
const M = signal2[mark];
if (M) M.listeners.forEach((l) => l(M.value));
if (M) M.listeners.forEach((l) => l(M.value, force));
}
}
return function(s) {
pendingSignals.add(s);
return function(s, force = false) {
pendingSignals.set(s, pendingSignals.get(s) || force);
if (scheduled) return;
scheduled = true;
queueMicrotask(flushSignals);
@ -738,11 +738,11 @@ function signal(value, actions) {
return create(false, value, actions);
if (isSignal(value)) return value;
const out = create(true);
function contextReWatch() {
function contextReWatch(_, force) {
const [origin, ...deps_old] = deps.get(contextReWatch);
deps.set(contextReWatch, /* @__PURE__ */ new Set([origin]));
stack_watch.push(contextReWatch);
write(out, value());
write(out, value(), force);
stack_watch.pop();
if (!deps_old.length) return;
const deps_curr = deps.get(contextReWatch);
@ -764,7 +764,7 @@ signal.action = function(s, name, ...a) {
throw new Error(`Action "${name}" not defined. See ${mark}.actions.`);
actions[name].apply(M, a);
if (M.skip) return delete M.skip;
queueSignalWrite(s);
queueSignalWrite(s, true);
};
signal.on = function on2(s, listener, options = {}) {
const { signal: as } = options;
@ -973,7 +973,7 @@ function write(s, value, force) {
const M = s[mark];
if (!M || !force && M.value === value) return;
M.value = value;
queueSignalWrite(s);
queueSignalWrite(s, force);
return value;
}
function addSignalListener(s, listener) {

4
dist/esm-with-signals.min.js vendored
View File

File diff suppressed because one or more lines are too long

20
dist/iife-with-signals.js vendored
View File

@ -734,19 +734,19 @@ var DDE = (() => {
// src/signals-lib/helpers.js
var mark = "__dde_signal";
var queueSignalWrite = /* @__PURE__ */ (() => {
let pendingSignals = /* @__PURE__ */ new Set();
let pendingSignals = /* @__PURE__ */ new Map();
let scheduled = false;
function flushSignals() {
scheduled = false;
const todo = pendingSignals;
pendingSignals = /* @__PURE__ */ new Set();
for (const signal2 of todo) {
pendingSignals = /* @__PURE__ */ new Map();
for (const [signal2, force] of todo) {
const M = signal2[mark];
if (M) M.listeners.forEach((l) => l(M.value));
if (M) M.listeners.forEach((l) => l(M.value, force));
}
}
return function(s) {
pendingSignals.add(s);
return function(s, force = false) {
pendingSignals.set(s, pendingSignals.get(s) || force);
if (scheduled) return;
scheduled = true;
queueMicrotask(flushSignals);
@ -783,11 +783,11 @@ var DDE = (() => {
return create(false, value, actions);
if (isSignal(value)) return value;
const out = create(true);
function contextReWatch() {
function contextReWatch(_, force) {
const [origin, ...deps_old] = deps.get(contextReWatch);
deps.set(contextReWatch, /* @__PURE__ */ new Set([origin]));
stack_watch.push(contextReWatch);
write(out, value());
write(out, value(), force);
stack_watch.pop();
if (!deps_old.length) return;
const deps_curr = deps.get(contextReWatch);
@ -809,7 +809,7 @@ var DDE = (() => {
throw new Error(`Action "${name}" not defined. See ${mark}.actions.`);
actions[name].apply(M, a);
if (M.skip) return delete M.skip;
queueSignalWrite(s);
queueSignalWrite(s, true);
};
signal.on = function on2(s, listener, options = {}) {
const { signal: as } = options;
@ -1018,7 +1018,7 @@ var DDE = (() => {
const M = s[mark];
if (!M || !force && M.value === value) return;
M.value = value;
queueSignalWrite(s);
queueSignalWrite(s, force);
return value;
}
function addSignalListener(s, listener) {

6
dist/iife-with-signals.min.js vendored
View File

File diff suppressed because one or more lines are too long

3
docs/components/examples/case-studies/task-manager.js
View File

@ -58,9 +58,6 @@ export function TaskManager() {
update(id, task) {
const current= this.value.find(t => t.id === id);
if (current) Object.assign(current, task);
// TODO: known bug for derived signals (the object is the same)
// so filteredTasks is not updated, hotfix ↙
this.value = structuredClone(this.value);
}
});
const newTaskTitle = S('');

16
src/signals-lib/helpers.js
View File

@ -9,7 +9,8 @@ export const mark= "__dde_signal";
* @type {Function}
*/
export const queueSignalWrite= (()=> {
let pendingSignals= new Set();
/** @type {Map<ddeSignal, boolean>} */
let pendingSignals= new Map();
let scheduled= false;
/**
@ -19,19 +20,20 @@ export const queueSignalWrite= (()=> {
function flushSignals() {
scheduled = false;
const todo= pendingSignals;
pendingSignals= new Set();
for(const signal of todo){
pendingSignals= new Map();
for(const [ signal, force ] of todo){
const M = signal[mark];
if(M) M.listeners.forEach(l => l(M.value));
if(M) M.listeners.forEach(l => l(M.value, force));
}
}
/**
* Queues a signal for update
* @param {Object} s - Signal to queue
* @param {ddeSignal} s - Signal to queue
* @param {boolean} force - Forced update
*/
return function(s){
pendingSignals.add(s);
return function(s, force= false){
pendingSignals.set(s, pendingSignals.get(s) || force);
if(scheduled) return;
scheduled = true;
queueMicrotask(flushSignals);

8
src/signals-lib/signals-lib.js
View File

@ -57,12 +57,12 @@ export function signal(value, actions){
* Updates the derived signal when dependencies change
* @private
*/
function contextReWatch(){
function contextReWatch(_, force){
const [ origin, ...deps_old ]= deps.get(contextReWatch);
deps.set(contextReWatch, new Set([ origin ]));
stack_watch.push(contextReWatch);
write(out, value());
write(out, value(), force);
stack_watch.pop();
if(!deps_old.length) return;
@ -95,7 +95,7 @@ signal.action= function(s, name, ...a){
throw new Error(`Action "${name}" not defined. See ${mark}.actions.`);
actions[name].apply(M, a);
if(M.skip) return (delete M.skip);
queueSignalWrite(s);
queueSignalWrite(s, true);
};
/**
@ -434,7 +434,7 @@ function write(s, value, force){
if(!M || (!force && M.value===value)) return;
M.value= value;
queueSignalWrite(s);
queueSignalWrite(s, force);
return value;
}