update dist

dist/index.js

@@ -1,2 +1,2 @@
-var v=function(...t){return{states:t}},A=function(t,...e){return{name:t,eventReactionCouplings:e}},h=function(t,...e){return{eventName:t,reactions:e}},F=function(t){return{type:"SideEffect",fn:t}},M=function(t){return{type:"Goto",targetStateName:t}},k=function(t){return{type:"ContextMutation",fn:t}},R=function(t,e){return{type:"SetPeer",name:t,peerCreationFunction:e}},w=function(t,e){return{type:"SetPeers",name:t,peerCreationFunction:e}},G=function(t,e){return{type:"AddPeers",name:t,peerCreationFunction:e}};function O(t,e,o){typeof o>"u"&&(o=t.states[0].name);let n={machine:t,state:o,context:e,eventQueue:[],isTransitioning:!1,peers:{},peerSubscriptionIds:new Map,subscriptionsToEvents:{},subscriptionsToState:{},subscriptionsToSettledState:{},isPaused:!0};return n.start=()=>(l(n),n),n.Peer=(i,r)=>(f(n,i,r),n),n.Peers=(i,r)=>(S(n,i,r),n),c(n,["entry",null]),n}function l(t){t.isPaused===!0&&(t.isPaused=!1,T(t))}function m(t){t.isPaused===!1&&(t.isPaused=!0)}function P(t){return t.machine.states.find(e=>e.name===t.state)}function y(t,e){return t.eventReactionCouplings.filter(o=>o.eventName===e[0])}function c(t,e){t.eventQueue.push(e),t.isTransitioning===!1&&T(t)}var Q=c;function T(t){for(t.isTransitioning=!0;t.eventQueue.length>0&&t.isPaused===!1;)g(t);t.isTransitioning=!1,Object.values(t.subscriptionsToSettledState).forEach(e=>{e(t)})}function g(t){let e=t.eventQueue.shift();if(typeof e<"u"){let o=P(t),i=y(o,e).map(s=>s.reactions).flat(),{sideEffects:r,contextMutations:u,peerings:x,goto_:p}=b(i),d=t.context;u.forEach(s=>{t.context=s.fn(t.context,e,t)}),p!==null&&(c(t,["exit",null]),t.state=p.targetStateName,Object.values(t.subscriptionsToState).forEach(s=>{s(e,t)}),c(t,["entry",null])),x.forEach(s=>{s.type==="SetPeer"?f(t,s.name,s.peerCreationFunction(t.context,e,t)):s.type==="SetPeers"?S(t,s.name,s.peerCreationFunction(t.context,e,t)):s.type==="AddPeers"&&E(t,s.name,s.peerCreationFunction(t.context,e,t))}),Object.values(t.subscriptionsToEvents).forEach(s=>{s(e,t)}),r.forEach(s=>{s.fn(t.context,e,t,d)})}}function b(t){let e=[],o=[],n=[],i=null;return t.forEach(r=>{r.type==="SideEffect"?e.push(r):r.type==="ContextMutation"?o.push(r):r.type==="SetPeer"?n.push(r):r.type==="Goto"&&(i=r)}),{sideEffects:e,contextMutations:o,peerings:n,goto_:i}}var a=0;function I(t,e){return a++,t.subscriptionsToSettledState[a.toString()]=e,a.toString()}var j=I;function N(t,e){return a++,t.subscriptionsToState[a.toString()]=e,a.toString()}function C(t,e){return a++,t.subscriptionsToEvents[a.toString()]=e,a.toString()}function _(t,e){delete t.subscriptionsToSettledState[e.toString()],delete t.subscriptionsToState[e.toString()],delete t.subscriptionsToEvents[e.toString()]}function f(t,e,o){t.peers.hasOwnProperty(e)&&_(t,t.peerSubscriptionIds.get(t.peers[e])),t.peers[e]=o;let n=C(o,(i,r)=>{t.isTransitioning===!1&&c(t,[e+"."+i[0],i[1]])});t.peerSubscriptionIds.set(o,n)}function S(t,e,o){t.peers.hasOwnProperty(e)&&t.peers[e].forEach(n=>{_(t,t.peerSubscriptionIds.get(n))}),t.peers[e]=o,o.forEach(n=>{let i=C(n,(r,u)=>{t.isTransitioning===!1&&c(t,[e+"."+r[0],r[1]])});t.peerSubscriptionIds.set(n,i)})}function E(t,e,o){t.peers.hasOwnProperty(e)||(t.peers[e]=[]),t.peers[e].concat(o),o.forEach(n=>{let i=C(n,(r,u)=>{t.isTransitioning===!1&&c(t,[e+"."+r[0],r[1]])});t.peerSubscriptionIds.set(n,i)})}export{G as AddPeers,k as Context,M as Goto,O as Interpreter,v as Machine,h as On,R as Peer,w as Peers,F as SideEffect,A as State,E as addPeers,Q as enqueue,m as pause,c as send,f as setPeer,S as setPeers,l as start,I as subscribe,C as subscribeToEvents,j as subscribeToSettledState,N as subscribeToState,_ as unsubscribe};
+var v=function(...t){return{states:t}},A=function(t,...e){return{name:t,eventReactionCouplings:e}},h=function(t,...e){return{eventName:t,reactions:e}},F=function(t){return{type:"SideEffect",fn:t}},M=function(t){return{type:"Goto",targetStateName:t}},k=function(t){return{type:"ContextMutation",fn:t}},R=function(t,e){return{type:"SetPeer",name:t,peerCreationFunction:e}},w=function(t,e){return{type:"SetPeers",name:t,peerCreationFunction:e}},G=function(t,e){return{type:"AddPeers",name:t,peerCreationFunction:e}};function O(t,e,o){typeof o>"u"&&(o=t.states[0].name);let n={machine:t,state:o,context:e,eventQueue:[],isTransitioning:!1,peers:{},peerSubscriptionIds:new Map,subscriptionsToEvents:{},subscriptionsToState:{},subscriptionsToSettledState:{},isPaused:!0};return n.start=()=>(l(n),n),n.Peer=(i,r)=>(f(n,i,r),n),n.Peers=(i,r)=>(S(n,i,r),n),c(n,["entry",null]),n}function l(t){t.isPaused===!0&&(t.isPaused=!1,T(t))}function m(t){t.isPaused===!1&&(t.isPaused=!0)}function P(t){return t.machine.states.find(e=>e.name===t.state)}function y(t,e){return t.eventReactionCouplings.filter(o=>o.eventName===e[0])}function c(t,e){t.eventQueue.push(e),t.isTransitioning===!1&&T(t)}var Q=c;function T(t){for(t.isTransitioning=!0;t.eventQueue.length>0&&t.isPaused===!1;)g(t);t.isTransitioning=!1,Object.values(t.subscriptionsToSettledState).forEach(e=>{e(t)})}function g(t){let e=t.eventQueue.shift();if(typeof e<"u"){let o=P(t),i=y(o,e).map(s=>s.reactions).flat(),{sideEffects:r,contextMutations:u,peerings:d,goto_:p}=b(i),x=t.context;u.forEach(s=>{t.context=s.fn(t.context,e,t)}),p!==null&&(c(t,["exit",null]),t.state=p.targetStateName,Object.values(t.subscriptionsToState).forEach(s=>{s(e,t)}),c(t,["entry",null])),d.forEach(s=>{s.type==="SetPeer"?f(t,s.name,s.peerCreationFunction(t.context,e,t)):s.type==="SetPeers"?S(t,s.name,s.peerCreationFunction(t.context,e,t)):s.type==="AddPeers"&&E(t,s.name,s.peerCreationFunction(t.context,e,t))}),Object.values(t.subscriptionsToEvents).forEach(s=>{s(e,t)}),r.forEach(s=>{s.fn(t.context,e,t,x)})}}function b(t){let e=[],o=[],n=[],i=null;return t.forEach(r=>{r.type==="SideEffect"?e.push(r):r.type==="ContextMutation"?o.push(r):r.type==="SetPeer"||r.type==="SetPeers"||r.type==="AddPeers"?n.push(r):r.type==="Goto"&&(i=r)}),{sideEffects:e,contextMutations:o,peerings:n,goto_:i}}var a=0;function I(t,e){return a++,t.subscriptionsToSettledState[a.toString()]=e,a.toString()}var j=I;function N(t,e){return a++,t.subscriptionsToState[a.toString()]=e,a.toString()}function C(t,e){return a++,t.subscriptionsToEvents[a.toString()]=e,a.toString()}function _(t,e){delete t.subscriptionsToSettledState[e.toString()],delete t.subscriptionsToState[e.toString()],delete t.subscriptionsToEvents[e.toString()]}function f(t,e,o){t.peers.hasOwnProperty(e)&&_(t,t.peerSubscriptionIds.get(t.peers[e])),t.peers[e]=o;let n=C(o,(i,r)=>{t.isTransitioning===!1&&c(t,[e+"."+i[0],i[1]])});t.peerSubscriptionIds.set(o,n)}function S(t,e,o){t.peers.hasOwnProperty(e)&&t.peers[e].forEach(n=>{_(t,t.peerSubscriptionIds.get(n))}),t.peers[e]=o,o.forEach(n=>{let i=C(n,(r,u)=>{t.isTransitioning===!1&&c(t,[e+"."+r[0],r[1]])});t.peerSubscriptionIds.set(n,i)})}function E(t,e,o){t.peers.hasOwnProperty(e)||(t.peers[e]=[]),t.peers[e].concat(o),o.forEach(n=>{let i=C(n,(r,u)=>{t.isTransitioning===!1&&c(t,[e+"."+r[0],r[1]])});t.peerSubscriptionIds.set(n,i)})}export{G as AddPeers,k as Context,M as Goto,O as Interpreter,v as Machine,h as On,R as Peer,w as Peers,F as SideEffect,A as State,E as addPeers,Q as enqueue,m as pause,c as send,f as setPeer,S as setPeers,l as start,I as subscribe,C as subscribeToEvents,j as subscribeToSettledState,N as subscribeToState,_ as unsubscribe};
 //# sourceMappingURL=index.js.map