@cdellacqua/signals
Advanced tools
Comparing version 4.1.0 to 4.1.1
@@ -86,3 +86,3 @@ function deriveSignal(signal$, transform) { | ||
function emit(v) { | ||
for (const subscriber of subscribers) { | ||
for (const subscriber of [...subscribers]) { | ||
subscriber(v); | ||
@@ -89,0 +89,0 @@ } |
@@ -1,1 +0,1 @@ | ||
(function(r,o){typeof exports=="object"&&typeof module!="undefined"?o(exports):typeof define=="function"&&define.amd?define(["exports"],o):(r=typeof globalThis!="undefined"?globalThis:r||self,o(r.signals={}))})(this,function(r){"use strict";function o(i,t){const c=f(),b=e=>{c.emit(t(e))},s=()=>{n&&c.nOfSubscriptions===0&&(n(),n=null)};let n=null;return{get nOfSubscriptions(){return c.nOfSubscriptions},subscribe:e=>{const u=c.subscribe(e);return n||(n=i.subscribe(b)),()=>{u(),s()}},subscribeOnce:e=>{const u=c.subscribeOnce(d=>{e(d),s()});return n||(n=i.subscribe(b)),()=>{u(),s()}}}}function l(i){const t=f(),c=n=>{t.emit(n)},b=()=>{s&&t.nOfSubscriptions===0&&(s.forEach(n=>n()),s=null)};let s=null;return{get nOfSubscriptions(){return t.nOfSubscriptions},subscribe:n=>{const e=t.subscribe(n);return s||(s=i.map(u=>u.subscribe(c))),()=>{e(),b()}},subscribeOnce:n=>{const e=t.subscribeOnce(u=>{n(u),b()});return s||(s=i.map(u=>u.subscribe(c))),()=>{e(),b()}}}}function f(){const i=[];function t(n){for(const e of i)e(n)}function c(n){const e=i.indexOf(n);e!==-1&&i.splice(e,1)}function b(n){return i.indexOf(n)===-1&&i.push(n),()=>c(n)}function s(n){const e=b(u=>{e(),n(u)});return e}return{emit:t,subscribe:b,subscribeOnce:s,get nOfSubscriptions(){return i.length}}}r.coalesceSignals=l,r.deriveSignal=o,r.makeSignal=f,Object.defineProperty(r,"__esModule",{value:!0}),r[Symbol.toStringTag]="Module"}); | ||
(function(r,o){typeof exports=="object"&&typeof module!="undefined"?o(exports):typeof define=="function"&&define.amd?define(["exports"],o):(r=typeof globalThis!="undefined"?globalThis:r||self,o(r.signals={}))})(this,function(r){"use strict";function o(i,t){const c=f(),b=e=>{c.emit(t(e))},s=()=>{n&&c.nOfSubscriptions===0&&(n(),n=null)};let n=null;return{get nOfSubscriptions(){return c.nOfSubscriptions},subscribe:e=>{const u=c.subscribe(e);return n||(n=i.subscribe(b)),()=>{u(),s()}},subscribeOnce:e=>{const u=c.subscribeOnce(d=>{e(d),s()});return n||(n=i.subscribe(b)),()=>{u(),s()}}}}function l(i){const t=f(),c=n=>{t.emit(n)},b=()=>{s&&t.nOfSubscriptions===0&&(s.forEach(n=>n()),s=null)};let s=null;return{get nOfSubscriptions(){return t.nOfSubscriptions},subscribe:n=>{const e=t.subscribe(n);return s||(s=i.map(u=>u.subscribe(c))),()=>{e(),b()}},subscribeOnce:n=>{const e=t.subscribeOnce(u=>{n(u),b()});return s||(s=i.map(u=>u.subscribe(c))),()=>{e(),b()}}}}function f(){const i=[];function t(n){for(const e of[...i])e(n)}function c(n){const e=i.indexOf(n);e!==-1&&i.splice(e,1)}function b(n){return i.indexOf(n)===-1&&i.push(n),()=>c(n)}function s(n){const e=b(u=>{e(),n(u)});return e}return{emit:t,subscribe:b,subscribeOnce:s,get nOfSubscriptions(){return i.length}}}r.coalesceSignals=l,r.deriveSignal=o,r.makeSignal=f,Object.defineProperty(r,"__esModule",{value:!0}),r[Symbol.toStringTag]="Module"}); |
@@ -5,3 +5,3 @@ { | ||
"description": "A simple signal pattern implementation that enables reactive programming", | ||
"version": "4.1.0", | ||
"version": "4.1.1", | ||
"type": "module", | ||
@@ -66,4 +66,4 @@ "types": "dist/index.d.ts", | ||
"ts-node": "^10.4.0", | ||
"typedoc": "^0.22.10", | ||
"typedoc-plugin-markdown": "^3.11.7", | ||
"typedoc": "^0.22.17", | ||
"typedoc-plugin-markdown": "^3.12.1", | ||
"typescript": "^4.3.2", | ||
@@ -70,0 +70,0 @@ "vite": "^2.6.4" |
@@ -31,4 +31,4 @@ # @cdellacqua/signals | ||
- `emit(value)`, to emit a value to all subscribers; | ||
- `subscribe(subscriber)`, to attach listeners; | ||
- `subscribeOnce(subscriber)`, to attach listeners for a single `emit` call; | ||
- `subscribe(subscriber)`, to attach subscribers; | ||
- `subscribeOnce(subscriber)`, to attach subscribers for a single `emit` call. | ||
@@ -35,0 +35,0 @@ When you subscribe to a signal, you get a unsubscribe function, e.g.: |
Sorry, the diff of this file is not supported yet
16859