@actorize/core - npm Package Compare versions

Comparing version 0.0.9 to 0.0.10

dist/lib/actor/actor.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"actor.js","sourceRoot":"","sources":["../../../src/actor/actor.ts"],"names":[],"mappings":";;;AAYA,SAAS,WAAW,CAAC,IAA4B,EAAE,IAAY;IAC3D,MAAM,SAAS,GAAG,CAAC,EAA6B,EAAE,EAAE;QAChD,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,SAAS,CAAC,IAAI,EAAE,EAAE,CAAC,CAAA;QAC5C,OAAO,KAAK,CAAA;IAChB,CAAC,CAAA;IACD,MAAM,WAAW,GAAG,KAAK,EAAE,SAAiB,EAAE,OAA+B,EAAE,EAAE;QAC7E,OAAO,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,SAAS,EAAE,OAAO,EAAE,IAAI,CAAC,CAAA;IAC3D,CAAC,CAAA;IACD,MAAM,iBAAiB,GAAG,KAAK,EAAE,OAA+B,EAAE,EAAE;QAChE,OAAO,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,IAAI,EAAE,OAAO,EAAE,IAAI,CAAC,CAAA;IACtD,CAAC,CAAA;IACD,OAAO;QACH,SAAS;QACT,WAAW;QACX,iBAAiB;KACpB,CAAA;AACL,CAAC;AAED,SAAgB,kBAAkB,CAAC,IAA4B;IAC3D,OAAO,WAAW,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,CAAA;AACvC,CAAC;AAFD,gDAEC"}
+{"version":3,"file":"actor.js","sourceRoot":"","sources":["../../../src/actor/actor.ts"],"names":[],"mappings":";;;AAYA,SAAS,WAAW,CAAC,IAA4B,EAAE,IAAY;IAC7D,MAAM,SAAS,GAAG,CAAC,EAA6B,EAAE,EAAE;QAClD,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,SAAS,CAAC,IAAI,EAAE,EAAE,CAAC,CAAA;QAC5C,OAAO,KAAK,CAAA;IACd,CAAC,CAAA;IACD,MAAM,WAAW,GAAG,KAAK,EAAE,SAAoB,EAAE,OAA+B,EAAE,EAAE;QAClF,OAAO,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,SAAS,EAAE,OAAO,EAAE,IAAI,CAAC,CAAA;IACzD,CAAC,CAAA;IACD,MAAM,iBAAiB,GAAG,KAAK,EAAE,OAA+B,EAAE,EAAE;QAClE,OAAO,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,IAAI,EAAE,OAAO,EAAE,IAAI,CAAC,CAAA;IACpD,CAAC,CAAA;IACD,OAAO;QACL,SAAS;QACT,WAAW;QACX,iBAAiB;KAClB,CAAA;AACH,CAAC;AAED,SAAgB,kBAAkB,CAAC,IAA4B;IAC7D,OAAO,WAAW,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,CAAA;AACrC,CAAC;AAFD,gDAEC"}

dist/lib/actor/director.js

@@ -5,4 +5,2 @@ "use strict";
 const actor_1 = require("./actor");
-// for now it just rejects the non local parts
-// TODO: patch those plugins and routers in here
 function patchStoreWithPlugins(store, routers) {
@@ -9,0 +7,0 @@ const pushMessage = async (recipient, payload, sender) => {

dist/lib/actor/director.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"director.js","sourceRoot":"","sources":["../../../src/actor/director.ts"],"names":[],"mappings":";;;AAAA,mCAAmD;AAanD,8CAA8C;AAC9C,gDAAgD;AAChD,SAAS,qBAAqB,CAAC,KAA4B,EAAE,OAAwB;IACnF,MAAM,WAAW,GAAG,KAAK,EAAE,SAAiB,EAAE,OAA+B,EAAE,MAAc,EAAE,EAAE;QAC/F,MAAM,cAAc,GAAG,SAAS,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QAC3C,MAAM,OAAO,GAAG,cAAc,CAAC,MAAM,KAAK,CAAC,CAAC;QAC5C,IAAI,CAAC,OAAO,EAAE;YACZ,MAAM,UAAU,GAAmB;gBACjC,MAAM,EAAE,cAAc,CAAC,CAAC,CAAC;gBACzB,OAAO,EAAE;oBACP,SAAS,EAAE,cAAc,CAAC,cAAc,CAAC,MAAM,GAAG,CAAC,CAAC;oBACpD,OAAO;oBACP,MAAM;iBACP;aACF,CAAA;YACD,MAAM,KAAK,GAAG,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE;gBAClC,MAAM,OAAO,GAAG,MAAM,CAAC,qBAAqB,CAAC,UAAU,EAAE,KAAK,CAAC,CAAA;gBAC/D,OAAO,OAAO,CAAA;YAChB,CAAC,CAAC,CAAA;YACF,OAAM;SACP;QACD,OAAO,KAAK,CAAC,WAAW,CAAC,SAAS,EAAE,OAAO,EAAE,MAAM,CAAC,CAAA;IACtD,CAAC,CAAA;IACD,OAAO;QACL,GAAG,KAAK;QACR,WAAW;KACZ,CAAA;AACH,CAAC;AAED,SAAgB,cAAc,CAAC,OAA8B;IAC3D,MAAM,EAAE,KAAK,EAAE,OAAO,GAAG,EAAE,EAAE,GAAG,OAAO,CAAA;IACvC,MAAM,YAAY,GAAG,qBAAqB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAA;IAC1D,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE;QACvB,MAAM,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE;YAC5B,CAAC,CAAC,gBAAgB,CAAC,CAAC,GAAmB,EAAE,EAAE;gBACzC,MAAM,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC,CAAC,CAAC,GAAG,GAAG,CAAC,MAAM,IAAI,GAAG,CAAC,OAAO,CAAC,SAAS,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,SAAS,CAAA;gBACxF,YAAY,CAAC,WAAW,CAAC,EAAE,EAAE,GAAG,CAAC,OAAO,CAAC,OAAO,EAAE,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAA;YACvE,CAAC,CAAC,CAAA;QACJ,CAAC,CAAC,CAAA;IACJ,CAAC,CAAC,CAAA;IACF,MAAM,WAAW,GAAG,0BAAkB,CAAC,EAAE,KAAK,EAAE,YAAY,EAAE,CAAC,CAAA;IAE/D,MAAM,aAAa,GAAG,CAAC,IAAY,EAAS,EAAE;QAC5C,MAAM,KAAK,GAAG,WAAW,CAAC,IAAI,CAAC,CAAA;QAC/B,OAAO,KAAK,CAAA;IACd,CAAC,CAAA;IACD,OAAO;QACL,aAAa;KACd,CAAA;AACH,CAAC;AApBD,wCAoBC"}
+{"version":3,"file":"director.js","sourceRoot":"","sources":["../../../src/actor/director.ts"],"names":[],"mappings":";;;AAAA,mCAAmD;AAanD,SAAS,qBAAqB,CAAC,KAA4B,EAAE,OAAwB;IACnF,MAAM,WAAW,GAAG,KAAK,EAAE,SAAoB,EAAE,OAA+B,EAAE,MAAc,EAAE,EAAE;QAClG,MAAM,cAAc,GAAG,SAAS,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QAC3C,MAAM,OAAO,GAAG,cAAc,CAAC,MAAM,KAAK,CAAC,CAAC;QAC5C,IAAI,CAAC,OAAO,EAAE;YACZ,MAAM,UAAU,GAAmB;gBACjC,MAAM,EAAE,cAAc,CAAC,CAAC,CAAC;gBACzB,OAAO,EAAE;oBACP,SAAS,EAAE,cAAc,CAAC,cAAc,CAAC,MAAM,GAAG,CAAC,CAAC;oBACpD,OAAO;oBACP,MAAM;iBACP;aACF,CAAA;YACD,MAAM,KAAK,GAAG,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE;gBAClC,MAAM,OAAO,GAAG,MAAM,CAAC,qBAAqB,CAAC,UAAU,EAAE,KAAK,CAAC,CAAA;gBAC/D,OAAO,OAAO,CAAA;YAChB,CAAC,CAAC,CAAA;YACF,OAAM;SACP;QACD,OAAO,KAAK,CAAC,WAAW,CAAC,SAAS,EAAE,OAAO,EAAE,MAAM,CAAC,CAAA;IACtD,CAAC,CAAA;IACD,OAAO;QACL,GAAG,KAAK;QACR,WAAW;KACZ,CAAA;AACH,CAAC;AAED,SAAgB,cAAc,CAAC,OAA8B;IAC3D,MAAM,EAAE,KAAK,EAAE,OAAO,GAAG,EAAE,EAAE,GAAG,OAAO,CAAA;IACvC,MAAM,YAAY,GAAG,qBAAqB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAA;IAC1D,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE;QACvB,MAAM,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE;YAC5B,CAAC,CAAC,gBAAgB,CAAC,CAAC,GAAmB,EAAE,EAAE;gBACzC,MAAM,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC,CAAC,CAAC,GAAG,GAAG,CAAC,MAAM,IAAI,GAAG,CAAC,OAAO,CAAC,SAAS,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,SAAS,CAAA;gBACxF,YAAY,CAAC,WAAW,CAAC,EAAE,EAAE,GAAG,CAAC,OAAO,CAAC,OAAO,EAAE,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAA;YACvE,CAAC,CAAC,CAAA;QACJ,CAAC,CAAC,CAAA;IACJ,CAAC,CAAC,CAAA;IACF,MAAM,WAAW,GAAG,0BAAkB,CAAC,EAAE,KAAK,EAAE,YAAY,EAAE,CAAC,CAAA;IAE/D,MAAM,aAAa,GAAG,CAAC,IAAY,EAAS,EAAE;QAC5C,MAAM,KAAK,GAAG,WAAW,CAAC,IAAI,CAAC,CAAA;QAC/B,OAAO,KAAK,CAAA;IACd,CAAC,CAAA;IACD,OAAO;QACL,aAAa;KACd,CAAA;AACH,CAAC;AApBD,wCAoBC"}

dist/lib/actor/dispatch.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"dispatch.js","sourceRoot":"","sources":["../../../src/actor/dispatch.ts"],"names":[],"mappings":";;;AAEA,oCAAuC;AAEhC,KAAK,UAAU,QAAQ,CAAC,QAAkB,EAAE,SAAiB,EAAE,OAA+B,EAAE,gBAAgB,GAAG,KAAK;IAC7H,MAAM,eAAe,GAAG,oBAAY,EAAE,CAAA;IACtC,MAAM,KAAK,GAAG,QAAQ,CAAC,aAAa,CAAC,eAAe,CAAC,CAAA;IACrD,IAAI,WAAyC,CAAA;IAC7C,IAAI,gBAAgB,EAAE;QACpB,WAAW,GAAG,IAAI,OAAO,CAAC,OAAO,CAAC,EAAE;YAClC,KAAK,CAAC,SAAS,CAAC,CAAC,IAAI,EAAE,EAAE;gBACvB,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAA;YAClB,CAAC,CAAC,CAAA;QACJ,CAAC,CAAC,CAAA;KACH;IAED,MAAM,KAAK,CAAC,WAAW,CAAC,SAAS,EAAE,OAAO,CAAC,CAAA;IAG3C,OAAO,WAAW,CAAA;AACpB,CAAC;AAhBD,4BAgBC"}
+{"version":3,"file":"dispatch.js","sourceRoot":"","sources":["../../../src/actor/dispatch.ts"],"names":[],"mappings":";;;AAEA,oCAAuC;AAEhC,KAAK,UAAU,QAAQ,CAAC,QAAkB,EAAE,SAAoB,EAAE,OAA+B,EAAE,gBAAgB,GAAG,KAAK;IAChI,MAAM,eAAe,GAAG,oBAAY,EAAE,CAAA;IACtC,MAAM,KAAK,GAAG,QAAQ,CAAC,aAAa,CAAC,eAAe,CAAC,CAAA;IACrD,IAAI,WAAyC,CAAA;IAC7C,IAAI,gBAAgB,EAAE;QACpB,WAAW,GAAG,IAAI,OAAO,CAAC,OAAO,CAAC,EAAE;YAClC,KAAK,CAAC,SAAS,CAAC,CAAC,IAAI,EAAE,EAAE;gBACvB,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAA;YAClB,CAAC,CAAC,CAAA;QACJ,CAAC,CAAC,CAAA;KACH;IAED,MAAM,KAAK,CAAC,WAAW,CAAC,SAAS,EAAE,OAAO,CAAC,CAAA;IAG3C,OAAO,WAAW,CAAA;AACpB,CAAC;AAhBD,4BAgBC"}

dist/lib/actor/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/actor/index.ts"],"names":[],"mappings":";;;AAAA,yCAAqD;AAI5C,+FAJA,yBAAc,OAIA;AAHvB,yCAAqC;AAGZ,yFAHhB,mBAAQ,OAGgB;AAFjC,mCAA8C;AAED,4FAFpC,mBAAW,OAEoC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/actor/index.ts"],"names":[],"mappings":";;;AAAA,yCAAqD;AAI5C,+FAJA,yBAAc,OAIA;AAHvB,yCAAqC;AAGZ,yFAHhB,mBAAQ,OAGgB;AAFjC,mCAAiF;AAEpC,4FAFpC,mBAAW,OAEoC"}

dist/lib/actor/store.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"store.js","sourceRoot":"","sources":["../../../src/actor/store.ts"],"names":[],"mappings":";;;AAaA,SAAgB,WAAW;IACzB,IAAI,QAAQ,GAAc,EAAE,CAAA;IAC5B,MAAM,SAAS,GAAwB,EAAE,CAAA;IAGzC,MAAM,WAAW,GAAG,KAAK,EAAE,SAAiB,EAAE,WAAW,GAAG,KAAK,EAAE,EAAE;QACnE,MAAM,gBAAgB,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE;YAC3C,OAAO,CAAC,CAAC,SAAS,KAAK,SAAS,IAAI,SAAS,KAAK,GAAG,CAAA;QACvD,CAAC,CAAC,CAAA;QACF,IAAI,CAAC,WAAW,EAAE;YAChB,QAAQ,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE;gBAC7B,OAAO,CAAC,CAAC,CAAC,CAAC,SAAS,KAAK,SAAS,IAAI,SAAS,KAAK,GAAG,CAAC,CAAA;YAC1D,CAAC,CAAC,CAAA;SACH;QACD,OAAO,gBAAgB,CAAA;IACzB,CAAC,CAAA;IAED,MAAM,WAAW,GAAG,KAAK,EAAE,SAAiB,EAAE,OAA+B,EAAE,MAAc,EAAE,EAAE;QAC/F,QAAQ,CAAC,IAAI,CAAC;YACZ,SAAS;YACT,OAAO;YACP,MAAM;SACP,CAAC,CAAA;QACF,IAAI,SAAS,CAAC,SAAS,CAAC,EAAE;YACxB,UAAU,CAAC,SAAS,CAAC,SAAS,CAAC,EAAE,CAAC,CAAC,CAAA;SACpC;IACH,CAAC,CAAA;IAED,MAAM,SAAS,GAAG,CAAC,SAAiB,EAAE,QAAkC,EAAE,EAAE;QAC1E,IAAI,OAAO,GAAG,CAAC,CAAC,CAAA;QAChB,MAAM,EAAE,GAAG,KAAK,IAAI,EAAE;YACpB,MAAM,IAAI,GAAG,MAAM,WAAW,CAAC,SAAS,CAAC,CAAA;YACzC,IAAI,IAAI,CAAC,MAAM,EAAE;gBACf,QAAQ,CAAC,IAAI,CAAC,CAAA;aACf;YAED,+BAA+B;QACjC,CAAC,CAAA;QACD,SAAS,CAAC,SAAS,CAAC,GAAG,EAAE,CAAA;QACzB,+BAA+B;QAC/B,OAAO,GAAG,EAAE;YACV,6BAA6B;YAC7B,OAAO,SAAS,CAAC,SAAS,CAAC,CAAA;QAC7B,CAAC,CAAA;IACH,CAAC,CAAA;IAED,OAAO;QACL,WAAW;QACX,WAAW;QACX,SAAS;KACV,CAAA;AACH,CAAC;AAnDD,kCAmDC"}
+{"version":3,"file":"store.js","sourceRoot":"","sources":["../../../src/actor/store.ts"],"names":[],"mappings":";;;AAeA,SAAgB,WAAW;IACzB,IAAI,QAAQ,GAAc,EAAE,CAAA;IAC5B,MAAM,SAAS,GAAwB,EAAE,CAAA;IAGzC,MAAM,WAAW,GAAG,KAAK,EAAE,SAAoB,EAAE,WAAW,GAAG,KAAK,EAAE,EAAE;QACtE,MAAM,gBAAgB,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE;YAC3C,OAAO,CAAC,CAAC,SAAS,KAAK,SAAS,IAAI,SAAS,KAAK,GAAG,CAAA;QACvD,CAAC,CAAC,CAAA;QACF,IAAI,CAAC,WAAW,EAAE;YAChB,QAAQ,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE;gBAC7B,OAAO,CAAC,CAAC,CAAC,CAAC,SAAS,KAAK,SAAS,IAAI,SAAS,KAAK,GAAG,CAAC,CAAA;YAC1D,CAAC,CAAC,CAAA;SACH;QACD,OAAO,gBAAgB,CAAA;IACzB,CAAC,CAAA;IAED,MAAM,WAAW,GAAG,KAAK,EAAE,SAAoB,EAAE,OAA+B,EAAE,MAAc,EAAE,EAAE;QAClG,QAAQ,CAAC,IAAI,CAAC;YACZ,SAAS;YACT,OAAO;YACP,MAAM;SACP,CAAC,CAAA;QACF,IAAI,SAAS,CAAC,SAAS,CAAC,EAAE;YACxB,UAAU,CAAC,SAAS,CAAC,SAAS,CAAC,EAAE,CAAC,CAAC,CAAA;SACpC;IACH,CAAC,CAAA;IAED,MAAM,SAAS,GAAG,CAAC,SAAoB,EAAE,QAAkC,EAAE,EAAE;QAC7E,IAAI,OAAO,GAAG,CAAC,CAAC,CAAA;QAChB,MAAM,EAAE,GAAG,KAAK,IAAI,EAAE;YACpB,MAAM,IAAI,GAAG,MAAM,WAAW,CAAC,SAAS,CAAC,CAAA;YACzC,IAAI,IAAI,CAAC,MAAM,EAAE;gBACf,QAAQ,CAAC,IAAI,CAAC,CAAA;aACf;YAED,+BAA+B;QACjC,CAAC,CAAA;QACD,SAAS,CAAC,SAAS,CAAC,GAAG,EAAE,CAAA;QACzB,+BAA+B;QAC/B,OAAO,GAAG,EAAE;YACV,6BAA6B;YAC7B,OAAO,SAAS,CAAC,SAAS,CAAC,CAAA;QAC7B,CAAC,CAAA;IACH,CAAC,CAAA;IAED,OAAO;QACL,WAAW;QACX,WAAW;QACX,SAAS;KACV,CAAA;AACH,CAAC;AAnDD,kCAmDC"}

dist/lib/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";;;AAAA,mCAAkF;AAKhF,+FALO,sBAAc,OAKP;AACd,yFANuB,gBAAQ,OAMvB;AAGR,4FAToD,mBAAW,OASpD;AARb,uCAAiH;AAS/G,uGATO,gCAAsB,OASP;AACtB,6FAV+B,sBAAY,OAU/B;AATd,qCAAgD;AAa9C,sGAbO,8BAAqB,OAaP"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";;;AAAA,mCAAqH;AAKnH,+FALO,sBAAc,OAKP;AACd,yFANuB,gBAAQ,OAMvB;AAGR,4FAToD,mBAAW,OASpD;AARb,uCAAiH;AAS/G,uGATO,gCAAsB,OASP;AACtB,6FAV+B,sBAAY,OAU/B;AATd,qCAAgD;AAa9C,sGAbO,8BAAqB,OAaP"}

dist/lib/worker/index.js

@@ -8,6 +8,6 @@ "use strict";
     worker.onmessage = (e) => {
-        ni.sendLocal(JSON.parse(e.data));
+        ni.sendLocal(e.data);
     };
     ni.handleLocalIncomingMessages((msg) => {
-        worker.postMessage(JSON.stringify(msg));
+        worker.postMessage(msg);
     });
@@ -14,0 +14,0 @@ return ni;

dist/lib/worker/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/worker/index.ts"],"names":[],"mappings":";;;AAAA,oCAAiD;AAE1C,MAAM,qBAAqB,GAAG,CAAC,MAAc,EAAE,EAAE;IACtD,MAAM,EAAE,GAAG,8BAAsB,EAAE,CAAA;IACnC,MAAM,CAAC,SAAS,GAAG,CAAC,CAAC,EAAE,EAAE;QACvB,EAAE,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAA;IAClC,CAAC,CAAA;IACD,EAAE,CAAC,2BAA2B,CAAC,CAAC,GAAG,EAAE,EAAE;QACrC,MAAM,CAAC,WAAW,CAAC,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,CAAA;IACzC,CAAC,CAAC,CAAA;IACF,OAAO,EAAE,CAAA;AACX,CAAC,CAAA;AATY,QAAA,qBAAqB,yBASjC;AAED,kBAAe,EAAE,CAAA"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/worker/index.ts"],"names":[],"mappings":";;;AAAA,oCAAiD;AAE1C,MAAM,qBAAqB,GAAG,CAAC,MAAc,EAAE,EAAE;IACtD,MAAM,EAAE,GAAG,8BAAsB,EAAE,CAAA;IACnC,MAAM,CAAC,SAAS,GAAG,CAAC,CAAC,EAAE,EAAE;QACvB,EAAE,CAAC,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,CAAA;IACtB,CAAC,CAAA;IACD,EAAE,CAAC,2BAA2B,CAAC,CAAC,GAAG,EAAE,EAAE;QACrC,MAAM,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;IACzB,CAAC,CAAC,CAAA;IACF,OAAO,EAAE,CAAA;AACX,CAAC,CAAA;AATY,QAAA,qBAAqB,yBASjC;AAED,kBAAe,EAAE,CAAA"}

dist/types/actor/actor.d.ts

@@ -1,5 +0,5 @@
-import { Message, PossibleMessagePayload, WatchableMessageStore } from './store';
+import { Message, PossibleMessagePayload, WatchableMessageStore, Recipient } from './store';
 export interface Actor {
     onMessage: (cb: (msgs: Message[]) => void) => () => void;
-    sendMessage: (recipient: string, payload: PossibleMessagePayload) => Promise<void>;
+    sendMessage: (recipient: Recipient, payload: PossibleMessagePayload) => Promise<void>;
     sendMessageToSelf: (payload: PossibleMessagePayload) => Promise<void>;
@@ -6,0 +6,0 @@ }

dist/types/actor/dispatch.d.ts

@@ -1,3 +0,3 @@
-import { PossibleMessagePayload, Message } from './store';
+import { PossibleMessagePayload, Message, Recipient } from './store';
 import { Director } from './director';
-export declare function dispatch(director: Director, recipient: string, payload: PossibleMessagePayload, waitTillResponse?: boolean): Promise<Message | undefined>;
+export declare function dispatch(director: Director, recipient: Recipient, payload: PossibleMessagePayload, waitTillResponse?: boolean): Promise<Message | undefined>;

dist/types/actor/index.d.ts

 import { createDirector, Director } from './director';
 import { dispatch } from './dispatch';
-import { createStore, Message } from './store';
-export { createDirector, dispatch, Director, createStore, Message };
+import { createStore, Message, Recipient, PossibleMessagePayload } from './store';
+export { createDirector, dispatch, Director, createStore, Message, Recipient, PossibleMessagePayload };

dist/types/actor/store.d.ts

@@ -0,4 +1,5 @@
+export declare type Recipient = string;
 export declare type PossibleMessagePayload = string | number | Record<string, any> | (string | number | Record<string, any>)[];
 export interface Message {
-    recipient: string;
+    recipient: Recipient;
     payload: PossibleMessagePayload;
@@ -8,10 +9,10 @@ sender: string;
 export interface WatchableMessageStore {
-    popMessages: (recipient: string, keepMessage?: boolean) => Promise<Message[]>;
-    pushMessage: (recipient: string, payload: PossibleMessagePayload, sender: string) => Promise<void>;
-    subscribe: (recipient: string, callback: (msg: Message[]) => void) => () => void;
+    popMessages: (recipient: Recipient, keepMessage?: boolean) => Promise<Message[]>;
+    pushMessage: (recipient: Recipient, payload: PossibleMessagePayload, sender: string) => Promise<void>;
+    subscribe: (recipient: Recipient, callback: (msg: Message[]) => void) => () => void;
 }
 export declare function createStore(): {
-    pushMessage: (recipient: string, payload: PossibleMessagePayload, sender: string) => Promise<void>;
-    popMessages: (recipient: string, keepMessage?: boolean) => Promise<Message[]>;
-    subscribe: (recipient: string, callback: (msg: Message[]) => void) => () => void;
+    pushMessage: (recipient: Recipient, payload: PossibleMessagePayload, sender: string) => Promise<void>;
+    popMessages: (recipient: Recipient, keepMessage?: boolean) => Promise<Message[]>;
+    subscribe: (recipient: Recipient, callback: (msg: Message[]) => void) => () => void;
 };

dist/types/index.d.ts

@@ -1,4 +0,4 @@
-import { createDirector, dispatch, Director, Message, createStore } from './actor';
+import { createDirector, dispatch, Director, Message, createStore, PossibleMessagePayload, Recipient } from './actor';
 import { createNetworkInterface, createRouter, NetworkInterface, NetworkMessage, NetworkRouter } from './network';
 import { createWorkerInterface } from './worker';
-export { createDirector, dispatch, Director, Message, createStore, createNetworkInterface, createRouter, NetworkInterface, NetworkMessage, NetworkRouter, createWorkerInterface, };
+export { createDirector, dispatch, Director, Message, createStore, createNetworkInterface, createRouter, NetworkInterface, NetworkMessage, NetworkRouter, createWorkerInterface, PossibleMessagePayload, Recipient, };

package.json

 {
   "name": "@actorize/core",
-  "version": "0.0.9",
+  "version": "0.0.10",
   "description": "Actorize helps building scalable js apps with a messaging system",
@@ -5,0 +5,0 @@ "keywords": [ "actor", "messaging", "system", "worker", "threads" ],

No alert changes

Improved metrics

Total package byte prevSize

22022

0.14%

Worsened metrics

Lines of code

329

-0.3%

No dependency changes