@cycle/run - npm Package Compare versions

Comparing version 5.0.0 to 5.1.0-rc.0

lib/cjs/microtask.d.ts

+/**
+ * Inspired by https://github.com/yoshuawuyts/nanotask, this function manages
+ * a queue of microtasks. It returns a "scheduleMicrotask" helper.
+ *
+ * Uses MutationObserver in the browser, supported by many browsers, including
+ * IE11.
+ *
+ * Uses process.nextTick in Node.js.
+ *
+ * Uses setTimeout otherwise.
+ */
+export default function microtask(): (fn: Function) => void;

lib/cjs/microtask.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+/**
+ * Inspired by https://github.com/yoshuawuyts/nanotask, this function manages
+ * a queue of microtasks. It returns a "scheduleMicrotask" helper.
+ *
+ * Uses MutationObserver in the browser, supported by many browsers, including
+ * IE11.
+ *
+ * Uses process.nextTick in Node.js.
+ *
+ * Uses setTimeout otherwise.
+ */
+function microtask() {
+    if (typeof MutationObserver !== 'undefined') {
+        var node_1 = document.createTextNode('');
+        var queue_1 = [];
+        var i_1 = 0;
+        new MutationObserver(function () {
+            while (queue_1.length) {
+                queue_1.shift()();
+            }
+        }).observe(node_1, { characterData: true });
+        return function (fn) {
+            queue_1.push(fn);
+            node_1.data = i_1 = 1 - i_1;
+        };
+    }
+    else if (typeof process !== 'undefined') {
+        return process.nextTick;
+    }
+    else {
+        return setTimeout;
+    }
+}
+exports.default = microtask;
+//# sourceMappingURL=microtask.js.map

lib/cjs/microtask.js.map

+{"version":3,"file":"microtask.js","sourceRoot":"","sources":["../../src/microtask.ts"],"names":[],"mappings":";;AAAA;;;;;;;;;;GAUG;AACH;IACE,EAAE,CAAC,CAAC,OAAO,gBAAgB,KAAK,WAAW,CAAC,CAAC,CAAC;QAC5C,IAAM,MAAI,GAAQ,QAAQ,CAAC,cAAc,CAAC,EAAE,CAAC,CAAC;QAC9C,IAAM,OAAK,GAAoB,EAAE,CAAC;QAClC,IAAI,GAAC,GAAG,CAAC,CAAC;QACV,IAAI,gBAAgB,CAAC;YACnB,OAAO,OAAK,CAAC,MAAM,EAAE,CAAC;gBACnB,OAAK,CAAC,KAAK,EAAe,EAAE,CAAC;YAChC,CAAC;QACH,CAAC,CAAC,CAAC,OAAO,CAAC,MAAI,EAAE,EAAC,aAAa,EAAE,IAAI,EAAC,CAAC,CAAC;QACxC,MAAM,CAAC,UAAS,EAAY;YAC1B,OAAK,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC;YACf,MAAI,CAAC,IAAI,GAAG,GAAC,GAAG,CAAC,GAAG,GAAC,CAAC;QACxB,CAAC,CAAC;IACJ,CAAC;IAAC,IAAI,CAAC,EAAE,CAAC,CAAC,OAAO,OAAO,KAAK,WAAW,CAAC,CAAC,CAAC;QAC1C,MAAM,CAAC,OAAO,CAAC,QAAQ,CAAC;IAC1B,CAAC;IAAC,IAAI,CAAC,CAAC;QACN,MAAM,CAAC,UAAU,CAAC;IACpB,CAAC;AACH,CAAC;AAnBD,4BAmBC"}

lib/es6/microtask.d.ts

+/**
+ * Inspired by https://github.com/yoshuawuyts/nanotask, this function manages
+ * a queue of microtasks. It returns a "scheduleMicrotask" helper.
+ *
+ * Uses MutationObserver in the browser, supported by many browsers, including
+ * IE11.
+ *
+ * Uses process.nextTick in Node.js.
+ *
+ * Uses setTimeout otherwise.
+ */
+export default function microtask(): (fn: Function) => void;

lib/es6/microtask.js

+/**
+ * Inspired by https://github.com/yoshuawuyts/nanotask, this function manages
+ * a queue of microtasks. It returns a "scheduleMicrotask" helper.
+ *
+ * Uses MutationObserver in the browser, supported by many browsers, including
+ * IE11.
+ *
+ * Uses process.nextTick in Node.js.
+ *
+ * Uses setTimeout otherwise.
+ */
+export default function microtask() {
+    if (typeof MutationObserver !== 'undefined') {
+        var node_1 = document.createTextNode('');
+        var queue_1 = [];
+        var i_1 = 0;
+        new MutationObserver(function () {
+            while (queue_1.length) {
+                queue_1.shift()();
+            }
+        }).observe(node_1, { characterData: true });
+        return function (fn) {
+            queue_1.push(fn);
+            node_1.data = i_1 = 1 - i_1;
+        };
+    }
+    else if (typeof process !== 'undefined') {
+        return process.nextTick;
+    }
+    else {
+        return setTimeout;
+    }
+}
+//# sourceMappingURL=microtask.js.map

lib/es6/microtask.js.map

+{"version":3,"file":"microtask.js","sourceRoot":"","sources":["../../src/microtask.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;GAUG;AACH,MAAM,CAAC,OAAO;IACZ,EAAE,CAAC,CAAC,OAAO,gBAAgB,KAAK,WAAW,CAAC,CAAC,CAAC;QAC5C,IAAM,MAAI,GAAQ,QAAQ,CAAC,cAAc,CAAC,EAAE,CAAC,CAAC;QAC9C,IAAM,OAAK,GAAoB,EAAE,CAAC;QAClC,IAAI,GAAC,GAAG,CAAC,CAAC;QACV,IAAI,gBAAgB,CAAC;YACnB,OAAO,OAAK,CAAC,MAAM,EAAE,CAAC;gBACnB,OAAK,CAAC,KAAK,EAAe,EAAE,CAAC;YAChC,CAAC;QACH,CAAC,CAAC,CAAC,OAAO,CAAC,MAAI,EAAE,EAAC,aAAa,EAAE,IAAI,EAAC,CAAC,CAAC;QACxC,MAAM,CAAC,UAAS,EAAY;YAC1B,OAAK,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC;YACf,MAAI,CAAC,IAAI,GAAG,GAAC,GAAG,CAAC,GAAG,GAAC,CAAC;QACxB,CAAC,CAAC;IACJ,CAAC;IAAC,IAAI,CAAC,EAAE,CAAC,CAAC,OAAO,OAAO,KAAK,WAAW,CAAC,CAAC,CAAC;QAC1C,MAAM,CAAC,OAAO,CAAC,QAAQ,CAAC;IAC1B,CAAC;IAAC,IAAI,CAAC,CAAC;QACN,MAAM,CAAC,UAAU,CAAC;IACpB,CAAC;AACH,CAAC"}

lib/adapt.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"adapt.js","sourceRoot":"","sources":["../../src/adapt.ts"],"names":[],"mappings":";;AAIA,SAAS,SAAS;IAChB,IAAI,SAAc,CAAC;IACnB,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACjC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACxC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM;QACL,SAAS,GAAG,IAAI,CAAC;KAClB;IACD,SAAS,CAAC,OAAO,GAAG,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC;IAC5C,SAAS,GAAG,SAAS,CAAC,OAAO,CAAC;IAC9B,SAAS,CAAC,WAAW,GAAG,SAAS,CAAC,WAAW,IAAK,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,EAAD,CAAC,CAAiB,CAAC;IAC3E,OAAO,SAAS,CAAC;AACnB,CAAC;AAMD,SAAgB,QAAQ,CAAC,CAAc;IACrC,SAAS,EAAE,CAAC,WAAW,GAAG,CAAC,CAAC;AAC9B,CAAC;AAFD,4BAEC;AAED,SAAgB,KAAK,CAAC,MAAmB;IACvC,OAAO,SAAS,EAAE,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;AACzC,CAAC;AAFD,sBAEC"}
+{"version":3,"file":"adapt.js","sourceRoot":"","sources":["../../src/adapt.ts"],"names":[],"mappings":";;AAIA;IACE,IAAI,SAAc,CAAC;IACnB,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACjC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACxC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM;QACL,SAAS,GAAG,IAAI,CAAC;KAClB;IACD,SAAS,CAAC,OAAO,GAAG,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC;IAC5C,SAAS,GAAG,SAAS,CAAC,OAAO,CAAC;IAC9B,SAAS,CAAC,WAAW,GAAG,SAAS,CAAC,WAAW,IAAK,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,EAAD,CAAC,CAAiB,CAAC;IAC3E,OAAO,SAAS,CAAC;AACnB,CAAC;AAMD,kBAAyB,CAAc;IACrC,SAAS,EAAE,CAAC,WAAW,GAAG,CAAC,CAAC;AAC9B,CAAC;AAFD,4BAEC;AAED,eAAsB,MAAmB;IACvC,OAAO,SAAS,EAAE,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;AACzC,CAAC;AAFD,sBAEC"}

lib/cjs/adapt.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"adapt.js","sourceRoot":"","sources":["../../src/adapt.ts"],"names":[],"mappings":";;AAIA,SAAS,SAAS;IAChB,IAAI,SAAc,CAAC;IACnB,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACjC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACxC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM;QACL,SAAS,GAAG,IAAI,CAAC;KAClB;IACD,SAAS,CAAC,OAAO,GAAG,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC;IAC5C,SAAS,GAAG,SAAS,CAAC,OAAO,CAAC;IAC9B,SAAS,CAAC,WAAW,GAAG,SAAS,CAAC,WAAW,IAAK,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,EAAD,CAAC,CAAiB,CAAC;IAC3E,OAAO,SAAS,CAAC;AACnB,CAAC;AAMD,SAAgB,QAAQ,CAAC,CAAc;IACrC,SAAS,EAAE,CAAC,WAAW,GAAG,CAAC,CAAC;AAC9B,CAAC;AAFD,4BAEC;AAED,SAAgB,KAAK,CAAC,MAAmB;IACvC,OAAO,SAAS,EAAE,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;AACzC,CAAC;AAFD,sBAEC"}
+{"version":3,"file":"adapt.js","sourceRoot":"","sources":["../../src/adapt.ts"],"names":[],"mappings":";;AAIA;IACE,IAAI,SAAc,CAAC;IACnB,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACjC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACxC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM;QACL,SAAS,GAAG,IAAI,CAAC;KAClB;IACD,SAAS,CAAC,OAAO,GAAG,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC;IAC5C,SAAS,GAAG,SAAS,CAAC,OAAO,CAAC;IAC9B,SAAS,CAAC,WAAW,GAAG,SAAS,CAAC,WAAW,IAAK,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,EAAD,CAAC,CAAiB,CAAC;IAC3E,OAAO,SAAS,CAAC;AACnB,CAAC;AAMD,kBAAyB,CAAc;IACrC,SAAS,EAAE,CAAC,WAAW,GAAG,CAAC,CAAC;AAC9B,CAAC;AAFD,4BAEC;AAED,eAAsB,MAAmB;IACvC,OAAO,SAAS,EAAE,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;AACzC,CAAC;AAFD,sBAEC"}

lib/cjs/index.d.ts

 import { CycleProgram, DisposeFunction, Drivers, MatchingDrivers, MatchingMain, Engine } from './types';
-export { FantasyObserver, FantasySubscription, FantasyObservable, DevToolEnabledSource, Sources, Sinks, SinkProxies, Driver, Drivers, DisposeFunction, MatchingDrivers, MatchingMain, Main, CycleProgram, Engine, } from './types';
+export { FantasyObserver, FantasySubscription, FantasyObservable, DevToolEnabledSource, Sources, Sinks, SinkProxies, Driver, Drivers, DisposeFunction, MatchingDrivers, MatchingMain, Main, CycleProgram, Engine } from './types';
 /**
@@ -4,0 +4,0 @@ * A function that prepares the Cycle application to be executed. Takes a `main`

lib/cjs/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";;AASA,yCAQqB;AAoBrB;;;;;;;;;;;;;;;;;;;;;;;;;;;GA2BG;AACH,SAAgB,KAAK,CAGnB,IAAO,EAAE,OAAU;IACnB,IAAI,OAAO,IAAI,KAAK,UAAU,EAAE;QAC9B,MAAM,IAAI,KAAK,CACb,mDAAmD,GAAG,WAAW,CAClE,CAAC;KACH;IACD,IAAI,OAAO,OAAO,KAAK,QAAQ,IAAI,OAAO,KAAK,IAAI,EAAE;QACnD,MAAM,IAAI,KAAK,CACb,mDAAmD;YACjD,sCAAsC,CACzC,CAAC;KACH;IACD,IAAI,yBAAa,CAAC,OAAO,CAAC,EAAE;QAC1B,MAAM,IAAI,KAAK,CACb,mDAAmD;YACjD,2DAA2D,CAC9D,CAAC;KACH;IAED,IAAM,MAAM,GAAG,aAAa,CAAC,OAAO,CAAC,CAAC;IACtC,IAAM,KAAK,GAAG,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC;IACnC,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QAChC,MAAc,CAAC,OAAO,GAAI,MAAc,CAAC,OAAO,IAAI,EAAE,CAAC;QACvD,MAAc,CAAC,OAAO,CAAC,KAAK,GAAG,KAAK,CAAC;KACvC;IACD,SAAS,IAAI;QACX,IAAM,UAAU,GAAG,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QACrC,OAAO,SAAS,OAAO;YACrB,UAAU,EAAE,CAAC;YACb,MAAM,CAAC,OAAO,EAAE,CAAC;QACnB,CAAC,CAAC;IACJ,CAAC;IACD,OAAO,EAAC,KAAK,OAAA,EAAE,OAAO,EAAE,MAAM,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,EAAC,CAAC;AACrD,CAAC;AApCD,sBAoCC;AAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAiCG;AACH,SAAgB,aAAa,CAAoB,OAAU;IACzD,IAAI,OAAO,OAAO,KAAK,QAAQ,IAAI,OAAO,KAAK,IAAI,EAAE;QACnD,MAAM,IAAI,KAAK,CACb,oDAAoD;YAClD,sCAAsC,CACzC,CAAC;KACH;IACD,IAAI,yBAAa,CAAC,OAAO,CAAC,EAAE;QAC1B,MAAM,IAAI,KAAK,CACb,oDAAoD;YAClD,2DAA2D,CAC9D,CAAC;KACH;IAED,IAAM,WAAW,GAAG,2BAAe,CAAC,OAAO,CAAC,CAAC;IAC7C,IAAM,UAAU,GAAG,uBAAW,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC;IACrD,IAAM,OAAO,GAAG,wBAAY,CAAC,UAAU,CAAC,CAAC;IACzC,SAAS,IAAI,CACX,KAAe;QAEf,OAAO,yBAAa,CAAC,KAAK,EAAE,WAAkB,CAAC,CAAC;IAClD,CAAC;IACD,SAAS,aAAa;QACpB,0BAAc,CAAC,OAAO,CAAC,CAAC;QACxB,8BAAkB,CAAC,WAAW,CAAC,CAAC;IAClC,CAAC;IACD,OAAO,EAAC,OAAO,SAAA,EAAE,GAAG,EAAE,IAAI,EAAE,OAAO,EAAE,aAAa,EAAC,CAAC;AACtD,CAAC;AA3BD,sCA2BC;AAED;;;;;;;;;;;;;;;;;;;;;;;;;;GA0BG;AACH,SAAgB,GAAG,CAGjB,IAAO,EAAE,OAAU;IACnB,IAAM,OAAO,GAAG,KAAK,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;IACrC,IACE,OAAO,MAAM,KAAK,WAAW;QAC5B,MAAc,CAAC,mCAAmC,EACnD;QACC,MAAc,CAAC,mCAAmC,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;KACpE;IACD,OAAO,OAAO,CAAC,GAAG,EAAE,CAAC;AACvB,CAAC;AAZD,kBAYC;AAED,kBAAe,GAAG,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";;AASA,yCAQqB;AAoBrB;;;;;;;;;;;;;;;;;;;;;;;;;;;GA2BG;AACH,eAGE,IAAO,EAAE,OAAU;IACnB,IAAI,OAAO,IAAI,KAAK,UAAU,EAAE;QAC9B,MAAM,IAAI,KAAK,CACb,mDAAmD,GAAG,WAAW,CAClE,CAAC;KACH;IACD,IAAI,OAAO,OAAO,KAAK,QAAQ,IAAI,OAAO,KAAK,IAAI,EAAE;QACnD,MAAM,IAAI,KAAK,CACb,mDAAmD;YACjD,sCAAsC,CACzC,CAAC;KACH;IACD,IAAI,yBAAa,CAAC,OAAO,CAAC,EAAE;QAC1B,MAAM,IAAI,KAAK,CACb,mDAAmD;YACjD,2DAA2D,CAC9D,CAAC;KACH;IAED,IAAM,MAAM,GAAG,aAAa,CAAC,OAAO,CAAC,CAAC;IACtC,IAAM,KAAK,GAAG,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC;IACnC,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QAChC,MAAc,CAAC,OAAO,GAAI,MAAc,CAAC,OAAO,IAAI,EAAE,CAAC;QACvD,MAAc,CAAC,OAAO,CAAC,KAAK,GAAG,KAAK,CAAC;KACvC;IACD;QACE,IAAM,UAAU,GAAG,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QACrC,OAAO;YACL,UAAU,EAAE,CAAC;YACb,MAAM,CAAC,OAAO,EAAE,CAAC;QACnB,CAAC,CAAC;IACJ,CAAC;IACD,OAAO,EAAC,KAAK,OAAA,EAAE,OAAO,EAAE,MAAM,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,EAAC,CAAC;AACrD,CAAC;AApCD,sBAoCC;AAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAiCG;AACH,uBAAiD,OAAU;IACzD,IAAI,OAAO,OAAO,KAAK,QAAQ,IAAI,OAAO,KAAK,IAAI,EAAE;QACnD,MAAM,IAAI,KAAK,CACb,oDAAoD;YAClD,sCAAsC,CACzC,CAAC;KACH;IACD,IAAI,yBAAa,CAAC,OAAO,CAAC,EAAE;QAC1B,MAAM,IAAI,KAAK,CACb,oDAAoD;YAClD,2DAA2D,CAC9D,CAAC;KACH;IAED,IAAM,WAAW,GAAG,2BAAe,CAAC,OAAO,CAAC,CAAC;IAC7C,IAAM,UAAU,GAAG,uBAAW,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC;IACrD,IAAM,OAAO,GAAG,wBAAY,CAAC,UAAU,CAAC,CAAC;IACzC,cACE,KAAe;QAEf,OAAO,yBAAa,CAAC,KAAK,EAAE,WAAkB,CAAC,CAAC;IAClD,CAAC;IACD;QACE,0BAAc,CAAC,OAAO,CAAC,CAAC;QACxB,8BAAkB,CAAC,WAAW,CAAC,CAAC;IAClC,CAAC;IACD,OAAO,EAAC,OAAO,SAAA,EAAE,GAAG,EAAE,IAAI,EAAE,OAAO,EAAE,aAAa,EAAC,CAAC;AACtD,CAAC;AA3BD,sCA2BC;AAED;;;;;;;;;;;;;;;;;;;;;;;;;;GA0BG;AACH,aAGE,IAAO,EAAE,OAAU;IACnB,IAAM,OAAO,GAAG,KAAK,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;IACrC,IACE,OAAO,MAAM,KAAK,WAAW;QAC5B,MAAc,CAAC,mCAAmC,EACnD;QACC,MAAc,CAAC,mCAAmC,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;KACpE;IACD,OAAO,OAAO,CAAC,GAAG,EAAE,CAAC;AACvB,CAAC;AAZD,kBAYC;AAED,kBAAe,GAAG,CAAC"}

lib/cjs/internals.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"internals.js","sourceRoot":"","sources":["../../src/internals.ts"],"names":[],"mappings":";;AAAA,mCAAmC;AACnC,uCAAkC;AAClC,iCAA8B;AAS9B,IAAM,iBAAiB,GAAG,mBAAS,EAAE,CAAC;AAEtC,SAAgB,eAAe,CAAoB,OAAU;IAC3D,IAAM,WAAW,GAAmB,EAAoB,CAAC;IACzD,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IAAI,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC,EAAE;YAChC,WAAW,CAAC,MAAI,CAAC,GAAG,iBAAE,CAAC,MAAM,EAAO,CAAC;SACtC;KACF;IACD,OAAO,WAAW,CAAC;AACrB,CAAC;AARD,0CAQC;AAED,SAAgB,WAAW,CACzB,OAAU,EACV,WAA2B;IAE3B,IAAM,OAAO,GAAe,EAAgB,CAAC;IAC7C,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IAAI,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC,EAAE;YAChC,OAAO,CAAC,MAAW,CAAC,GAAG,OAAO,CAAC,MAAI,CAAC,CAAC,WAAW,CAAC,MAAI,CAAC,EAAE,MAAI,CAAC,CAAC;YAC9D,IAAI,OAAO,CAAC,MAAW,CAAC,IAAI,OAAO,OAAO,CAAC,MAAW,CAAC,KAAK,QAAQ,EAAE;gBACnE,OAAO,CAAC,MAAW,CAA0B,CAAC,cAAc,GAAG,MAAI,CAAC;aACtE;SACF;KACF;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAdD,kCAcC;AAED,oCAAoC;AACpC,SAAgB,YAAY,CAAK,OAAW;IAC1C,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IACE,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC;YAC5B,OAAO,CAAC,MAAI,CAAC;YACb,OAAS,OAAO,CAAC,MAAI,CAAyB,CAAC,kBAAkB;gBAC/D,UAAU,EACZ;YACA,OAAO,CAAC,MAAI,CAAC,GAAG,aAAK,CAAE,OAAO,CAAC,MAAI,CAAwB,CAAC,CAAC;SAC9D;KACF;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAZD,oCAYC;AAyBD,SAAgB,aAAa,CAC3B,KAAS,EACT,WAA4B;IAE5B,IAAM,SAAS,GAAoB,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,MAAM,CAC1D,UAAA,IAAI,IAAI,OAAA,CAAC,CAAC,WAAW,CAAC,IAAI,CAAC,EAAnB,CAAmB,CAC5B,CAAC;IAEF,IAAI,OAAO,GAA2B,EAA4B,CAAC;IACnE,IAAM,WAAW,GAAwB,EAAyB,CAAC;IACnE,SAAS,CAAC,OAAO,CAAC,UAAA,IAAI;QACpB,OAAO,CAAC,IAAI,CAAC,GAAG,EAAC,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,EAAC,CAAC;QACjC,WAAW,CAAC,IAAI,CAAC,GAAG;YAClB,IAAI,EAAE,UAAC,CAAM,IAAK,OAAA,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,EAAxB,CAAwB;YAC1C,KAAK,EAAE,UAAC,GAAQ,IAAK,OAAA,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,EAA1B,CAA0B;YAC/C,QAAQ,EAAE,cAAO,CAAC;SACnB,CAAC;IACJ,CAAC,CAAC,CAAC;IAEH,IAAM,aAAa,GAAG,SAAS,CAAC,GAAG,CAAC,UAAA,IAAI;QACtC,OAAA,iBAAE,CAAC,cAAc,CAAC,KAAK,CAAC,IAAI,CAAQ,CAAC,CAAC,SAAS,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;IAAlE,CAAkE,CACnE,CAAC;IAEF,SAAS,CAAC,OAAO,CAAC,UAAA,IAAI;QACpB,IAAM,QAAQ,GAAG,WAAW,CAAC,IAAI,CAAC,CAAC;QACnC,IAAM,IAAI,GAAG,UAAC,CAAM;YAClB,iBAAiB,CAAC,cAAM,OAAA,QAAQ,CAAC,EAAE,CAAC,CAAC,CAAC,EAAd,CAAc,CAAC,CAAC;QAC1C,CAAC,CAAC;QACF,IAAM,KAAK,GAAG,UAAC,GAAQ;YACrB,iBAAiB,CAAC;gBAChB,CAAC,OAAO,CAAC,KAAK,IAAI,OAAO,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,CAAC;gBACpC,QAAQ,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC;YACnB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;QACF,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC/B,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QAChC,WAAW,CAAC,IAAI,CAAC,CAAC,IAAI,GAAG,IAAI,CAAC;QAC9B,WAAW,CAAC,IAAI,CAAC,CAAC,KAAK,GAAG,KAAK,CAAC;QAChC,mEAAmE;QACnE,yCAAyC;QACzC,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,IAAI,CAAC;QAC5B,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,KAAK,CAAC;IAC/B,CAAC,CAAC,CAAC;IACH,OAAO,GAAG,IAAW,CAAC,CAAC,iBAAiB;IAExC,OAAO,SAAS,kBAAkB;QAChC,aAAa,CAAC,OAAO,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,CAAC,WAAW,EAAE,EAAf,CAAe,CAAC,CAAC;IAC9C,CAAC,CAAC;AACJ,CAAC;AAhDD,sCAgDC;AAED,SAAgB,kBAAkB,CAAK,WAA4B;IACjE,MAAM,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC,OAAO,CAAC,UAAA,IAAI,IAAI,OAAA,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,EAAE,EAAtB,CAAsB,CAAC,CAAC;AACnE,CAAC;AAFD,gDAEC;AAED,SAAgB,cAAc,CAAK,OAAW;IAC5C,KAAK,IAAM,CAAC,IAAI,OAAO,EAAE;QACvB,IACE,OAAO,CAAC,cAAc,CAAC,CAAC,CAAC;YACzB,OAAO,CAAC,CAAC,CAAC;YACT,OAAO,CAAC,CAAC,CAAS,CAAC,OAAO,EAC3B;YACC,OAAO,CAAC,CAAC,CAAS,CAAC,OAAO,EAAE,CAAC;SAC/B;KACF;AACH,CAAC;AAVD,wCAUC;AAED,SAAgB,aAAa,CAAC,GAAQ;IACpC,OAAO,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,MAAM,KAAK,CAAC,CAAC;AACvC,CAAC;AAFD,sCAEC"}
+{"version":3,"file":"internals.js","sourceRoot":"","sources":["../../src/internals.ts"],"names":[],"mappings":";;AAAA,mCAAmC;AACnC,uCAAkC;AAClC,iCAA8B;AAS9B,IAAM,iBAAiB,GAAG,mBAAS,EAAE,CAAC;AAEtC,yBAAmD,OAAU;IAC3D,IAAM,WAAW,GAAmB,EAAoB,CAAC;IACzD,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IAAI,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC,EAAE;YAChC,WAAW,CAAC,MAAI,CAAC,GAAG,iBAAE,CAAC,MAAM,EAAO,CAAC;SACtC;KACF;IACD,OAAO,WAAW,CAAC;AACrB,CAAC;AARD,0CAQC;AAED,qBACE,OAAU,EACV,WAA2B;IAE3B,IAAM,OAAO,GAAe,EAAgB,CAAC;IAC7C,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IAAI,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC,EAAE;YAChC,OAAO,CAAC,MAAW,CAAC,GAAG,OAAO,CAAC,MAAI,CAAC,CAAC,WAAW,CAAC,MAAI,CAAC,EAAE,MAAI,CAAC,CAAC;YAC9D,IAAI,OAAO,CAAC,MAAW,CAAC,IAAI,OAAO,OAAO,CAAC,MAAW,CAAC,KAAK,QAAQ,EAAE;gBACnE,OAAO,CAAC,MAAW,CAA0B,CAAC,cAAc,GAAG,MAAI,CAAC;aACtE;SACF;KACF;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAdD,kCAcC;AAED,oCAAoC;AACpC,sBAAiC,OAAW;IAC1C,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IACE,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC;YAC5B,OAAO,CAAC,MAAI,CAAC;YACb,OAAS,OAAO,CAAC,MAAI,CAAyB,CAAC,kBAAkB;gBAC/D,UAAU,EACZ;YACA,OAAO,CAAC,MAAI,CAAC,GAAG,aAAK,CAAE,OAAO,CAAC,MAAI,CAAwB,CAAC,CAAC;SAC9D;KACF;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAZD,oCAYC;AAyBD,uBACE,KAAS,EACT,WAA4B;IAE5B,IAAM,SAAS,GAAoB,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,MAAM,CAC1D,UAAA,IAAI,IAAI,OAAA,CAAC,CAAC,WAAW,CAAC,IAAI,CAAC,EAAnB,CAAmB,CAC5B,CAAC;IAEF,IAAI,OAAO,GAA2B,EAA4B,CAAC;IACnE,IAAM,WAAW,GAAwB,EAAyB,CAAC;IACnE,SAAS,CAAC,OAAO,CAAC,UAAA,IAAI;QACpB,OAAO,CAAC,IAAI,CAAC,GAAG,EAAC,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,EAAC,CAAC;QACjC,WAAW,CAAC,IAAI,CAAC,GAAG;YAClB,IAAI,EAAE,UAAC,CAAM,IAAK,OAAA,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,EAAxB,CAAwB;YAC1C,KAAK,EAAE,UAAC,GAAQ,IAAK,OAAA,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,EAA1B,CAA0B;YAC/C,QAAQ,EAAE,cAAO,CAAC;SACnB,CAAC;IACJ,CAAC,CAAC,CAAC;IAEH,IAAM,aAAa,GAAG,SAAS,CAAC,GAAG,CAAC,UAAA,IAAI;QACtC,OAAA,iBAAE,CAAC,cAAc,CAAC,KAAK,CAAC,IAAI,CAAQ,CAAC,CAAC,SAAS,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;IAAlE,CAAkE,CACnE,CAAC;IAEF,SAAS,CAAC,OAAO,CAAC,UAAA,IAAI;QACpB,IAAM,QAAQ,GAAG,WAAW,CAAC,IAAI,CAAC,CAAC;QACnC,IAAM,IAAI,GAAG,UAAC,CAAM;YAClB,iBAAiB,CAAC,cAAM,OAAA,QAAQ,CAAC,EAAE,CAAC,CAAC,CAAC,EAAd,CAAc,CAAC,CAAC;QAC1C,CAAC,CAAC;QACF,IAAM,KAAK,GAAG,UAAC,GAAQ;YACrB,iBAAiB,CAAC;gBAChB,CAAC,OAAO,CAAC,KAAK,IAAI,OAAO,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,CAAC;gBACpC,QAAQ,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC;YACnB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;QACF,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC/B,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QAChC,WAAW,CAAC,IAAI,CAAC,CAAC,IAAI,GAAG,IAAI,CAAC;QAC9B,WAAW,CAAC,IAAI,CAAC,CAAC,KAAK,GAAG,KAAK,CAAC;QAChC,mEAAmE;QACnE,yCAAyC;QACzC,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,IAAI,CAAC;QAC5B,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,KAAK,CAAC;IAC/B,CAAC,CAAC,CAAC;IACH,OAAO,GAAG,IAAW,CAAC,CAAC,iBAAiB;IAExC,OAAO;QACL,aAAa,CAAC,OAAO,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,CAAC,WAAW,EAAE,EAAf,CAAe,CAAC,CAAC;IAC9C,CAAC,CAAC;AACJ,CAAC;AAhDD,sCAgDC;AAED,4BAAuC,WAA4B;IACjE,MAAM,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC,OAAO,CAAC,UAAA,IAAI,IAAI,OAAA,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,EAAE,EAAtB,CAAsB,CAAC,CAAC;AACnE,CAAC;AAFD,gDAEC;AAED,wBAAmC,OAAW;IAC5C,KAAK,IAAM,CAAC,IAAI,OAAO,EAAE;QACvB,IACE,OAAO,CAAC,cAAc,CAAC,CAAC,CAAC;YACzB,OAAO,CAAC,CAAC,CAAC;YACT,OAAO,CAAC,CAAC,CAAS,CAAC,OAAO,EAC3B;YACC,OAAO,CAAC,CAAC,CAAS,CAAC,OAAO,EAAE,CAAC;SAC/B;KACF;AACH,CAAC;AAVD,wCAUC;AAED,uBAA8B,GAAQ;IACpC,OAAO,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,MAAM,KAAK,CAAC,CAAC;AACvC,CAAC;AAFD,sCAEC"}

lib/cjs/types.d.ts

@@ -24,3 +24,3 @@ import { Stream } from 'xstream';
 export declare type Drivers = {
-    [name: string]: Driver<FantasyObservable | undefined | void | null, any>;
+    [name: string]: Driver<Stream<any> | void, any | void>;
 };
@@ -31,5 +31,3 @@ export declare type Main = (...args: Array<any>) => any;
 };
-export declare type Sinks<M extends Main> = {
-    [k in (string & keyof ReturnType<M>)]: ReturnType<M>[k] & FantasyObservable;
-};
+export declare type Sinks<M extends Main> = ReturnType<M>;
 export declare type MatchingMain<D extends Drivers, M extends Main> = Main & {
@@ -39,3 +37,3 @@ (so?: Partial<Sources<D>>): Sinks<M>;
 export declare type MatchingDrivers<D extends Drivers, M extends Main> = Drivers & {
-    [k in (string & keyof Sinks<M>)]: ((si?: Sinks<M>[k]) => Sources<D>[k]) | ((si: Sinks<M>[k]) => Sources<D>[k]);
+    [k in string & keyof Sinks<M>]: ((si?: Sinks<M>[k]) => Sources<D>[k]) | ((si: Sinks<M>[k]) => Sources<D>[k]);
 };
@@ -42,0 +40,0 @@ export interface CycleProgram<D extends MatchingDrivers<D, M>, M extends MatchingMain<D, M>> {

lib/es6/adapt.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"adapt.js","sourceRoot":"","sources":["../../src/adapt.ts"],"names":[],"mappings":"AAIA,SAAS,SAAS;IAChB,IAAI,SAAc,CAAC;IACnB,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACjC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACxC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM;QACL,SAAS,GAAG,IAAI,CAAC;KAClB;IACD,SAAS,CAAC,OAAO,GAAG,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC;IAC5C,SAAS,GAAG,SAAS,CAAC,OAAO,CAAC;IAC9B,SAAS,CAAC,WAAW,GAAG,SAAS,CAAC,WAAW,IAAK,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,EAAD,CAAC,CAAiB,CAAC;IAC3E,OAAO,SAAS,CAAC;AACnB,CAAC;AAMD,MAAM,UAAU,QAAQ,CAAC,CAAc;IACrC,SAAS,EAAE,CAAC,WAAW,GAAG,CAAC,CAAC;AAC9B,CAAC;AAED,MAAM,UAAU,KAAK,CAAC,MAAmB;IACvC,OAAO,SAAS,EAAE,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;AACzC,CAAC"}
+{"version":3,"file":"adapt.js","sourceRoot":"","sources":["../../src/adapt.ts"],"names":[],"mappings":"AAIA;IACE,IAAI,SAAc,CAAC;IACnB,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACjC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QACxC,SAAS,GAAG,MAAM,CAAC;KACpB;SAAM;QACL,SAAS,GAAG,IAAI,CAAC;KAClB;IACD,SAAS,CAAC,OAAO,GAAG,SAAS,CAAC,OAAO,IAAI,EAAE,CAAC;IAC5C,SAAS,GAAG,SAAS,CAAC,OAAO,CAAC;IAC9B,SAAS,CAAC,WAAW,GAAG,SAAS,CAAC,WAAW,IAAK,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,EAAD,CAAC,CAAiB,CAAC;IAC3E,OAAO,SAAS,CAAC;AACnB,CAAC;AAMD,MAAM,mBAAmB,CAAc;IACrC,SAAS,EAAE,CAAC,WAAW,GAAG,CAAC,CAAC;AAC9B,CAAC;AAED,MAAM,gBAAgB,MAAmB;IACvC,OAAO,SAAS,EAAE,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;AACzC,CAAC"}

lib/es6/index.d.ts

 import { CycleProgram, DisposeFunction, Drivers, MatchingDrivers, MatchingMain, Engine } from './types';
-export { FantasyObserver, FantasySubscription, FantasyObservable, DevToolEnabledSource, Sources, Sinks, SinkProxies, Driver, Drivers, DisposeFunction, MatchingDrivers, MatchingMain, Main, CycleProgram, Engine, } from './types';
+export { FantasyObserver, FantasySubscription, FantasyObservable, DevToolEnabledSource, Sources, Sinks, SinkProxies, Driver, Drivers, DisposeFunction, MatchingDrivers, MatchingMain, Main, CycleProgram, Engine } from './types';
 /**
@@ -4,0 +4,0 @@ * A function that prepares the Cycle application to be executed. Takes a `main`

lib/es6/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AASA,OAAO,EACL,YAAY,EACZ,WAAW,EACX,eAAe,EACf,cAAc,EACd,kBAAkB,EAClB,aAAa,EACb,aAAa,GACd,MAAM,aAAa,CAAC;AAoBrB;;;;;;;;;;;;;;;;;;;;;;;;;;;GA2BG;AACH,MAAM,UAAU,KAAK,CAGnB,IAAO,EAAE,OAAU;IACnB,IAAI,OAAO,IAAI,KAAK,UAAU,EAAE;QAC9B,MAAM,IAAI,KAAK,CACb,mDAAmD,GAAG,WAAW,CAClE,CAAC;KACH;IACD,IAAI,OAAO,OAAO,KAAK,QAAQ,IAAI,OAAO,KAAK,IAAI,EAAE;QACnD,MAAM,IAAI,KAAK,CACb,mDAAmD;YACjD,sCAAsC,CACzC,CAAC;KACH;IACD,IAAI,aAAa,CAAC,OAAO,CAAC,EAAE;QAC1B,MAAM,IAAI,KAAK,CACb,mDAAmD;YACjD,2DAA2D,CAC9D,CAAC;KACH;IAED,IAAM,MAAM,GAAG,aAAa,CAAC,OAAO,CAAC,CAAC;IACtC,IAAM,KAAK,GAAG,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC;IACnC,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QAChC,MAAc,CAAC,OAAO,GAAI,MAAc,CAAC,OAAO,IAAI,EAAE,CAAC;QACvD,MAAc,CAAC,OAAO,CAAC,KAAK,GAAG,KAAK,CAAC;KACvC;IACD,SAAS,IAAI;QACX,IAAM,UAAU,GAAG,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QACrC,OAAO,SAAS,OAAO;YACrB,UAAU,EAAE,CAAC;YACb,MAAM,CAAC,OAAO,EAAE,CAAC;QACnB,CAAC,CAAC;IACJ,CAAC;IACD,OAAO,EAAC,KAAK,OAAA,EAAE,OAAO,EAAE,MAAM,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,EAAC,CAAC;AACrD,CAAC;AAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAiCG;AACH,MAAM,UAAU,aAAa,CAAoB,OAAU;IACzD,IAAI,OAAO,OAAO,KAAK,QAAQ,IAAI,OAAO,KAAK,IAAI,EAAE;QACnD,MAAM,IAAI,KAAK,CACb,oDAAoD;YAClD,sCAAsC,CACzC,CAAC;KACH;IACD,IAAI,aAAa,CAAC,OAAO,CAAC,EAAE;QAC1B,MAAM,IAAI,KAAK,CACb,oDAAoD;YAClD,2DAA2D,CAC9D,CAAC;KACH;IAED,IAAM,WAAW,GAAG,eAAe,CAAC,OAAO,CAAC,CAAC;IAC7C,IAAM,UAAU,GAAG,WAAW,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC;IACrD,IAAM,OAAO,GAAG,YAAY,CAAC,UAAU,CAAC,CAAC;IACzC,SAAS,IAAI,CACX,KAAe;QAEf,OAAO,aAAa,CAAC,KAAK,EAAE,WAAkB,CAAC,CAAC;IAClD,CAAC;IACD,SAAS,aAAa;QACpB,cAAc,CAAC,OAAO,CAAC,CAAC;QACxB,kBAAkB,CAAC,WAAW,CAAC,CAAC;IAClC,CAAC;IACD,OAAO,EAAC,OAAO,SAAA,EAAE,GAAG,EAAE,IAAI,EAAE,OAAO,EAAE,aAAa,EAAC,CAAC;AACtD,CAAC;AAED;;;;;;;;;;;;;;;;;;;;;;;;;;GA0BG;AACH,MAAM,UAAU,GAAG,CAGjB,IAAO,EAAE,OAAU;IACnB,IAAM,OAAO,GAAG,KAAK,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;IACrC,IACE,OAAO,MAAM,KAAK,WAAW;QAC5B,MAAc,CAAC,mCAAmC,EACnD;QACC,MAAc,CAAC,mCAAmC,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;KACpE;IACD,OAAO,OAAO,CAAC,GAAG,EAAE,CAAC;AACvB,CAAC;AAED,eAAe,GAAG,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AASA,OAAO,EACL,YAAY,EACZ,WAAW,EACX,eAAe,EACf,cAAc,EACd,kBAAkB,EAClB,aAAa,EACb,aAAa,GACd,MAAM,aAAa,CAAC;AAoBrB;;;;;;;;;;;;;;;;;;;;;;;;;;;GA2BG;AACH,MAAM,gBAGJ,IAAO,EAAE,OAAU;IACnB,IAAI,OAAO,IAAI,KAAK,UAAU,EAAE;QAC9B,MAAM,IAAI,KAAK,CACb,mDAAmD,GAAG,WAAW,CAClE,CAAC;KACH;IACD,IAAI,OAAO,OAAO,KAAK,QAAQ,IAAI,OAAO,KAAK,IAAI,EAAE;QACnD,MAAM,IAAI,KAAK,CACb,mDAAmD;YACjD,sCAAsC,CACzC,CAAC;KACH;IACD,IAAI,aAAa,CAAC,OAAO,CAAC,EAAE;QAC1B,MAAM,IAAI,KAAK,CACb,mDAAmD;YACjD,2DAA2D,CAC9D,CAAC;KACH;IAED,IAAM,MAAM,GAAG,aAAa,CAAC,OAAO,CAAC,CAAC;IACtC,IAAM,KAAK,GAAG,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC;IACnC,IAAI,OAAO,MAAM,KAAK,WAAW,EAAE;QAChC,MAAc,CAAC,OAAO,GAAI,MAAc,CAAC,OAAO,IAAI,EAAE,CAAC;QACvD,MAAc,CAAC,OAAO,CAAC,KAAK,GAAG,KAAK,CAAC;KACvC;IACD;QACE,IAAM,UAAU,GAAG,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QACrC,OAAO;YACL,UAAU,EAAE,CAAC;YACb,MAAM,CAAC,OAAO,EAAE,CAAC;QACnB,CAAC,CAAC;IACJ,CAAC;IACD,OAAO,EAAC,KAAK,OAAA,EAAE,OAAO,EAAE,MAAM,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,EAAC,CAAC;AACrD,CAAC;AAED;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAiCG;AACH,MAAM,wBAA2C,OAAU;IACzD,IAAI,OAAO,OAAO,KAAK,QAAQ,IAAI,OAAO,KAAK,IAAI,EAAE;QACnD,MAAM,IAAI,KAAK,CACb,oDAAoD;YAClD,sCAAsC,CACzC,CAAC;KACH;IACD,IAAI,aAAa,CAAC,OAAO,CAAC,EAAE;QAC1B,MAAM,IAAI,KAAK,CACb,oDAAoD;YAClD,2DAA2D,CAC9D,CAAC;KACH;IAED,IAAM,WAAW,GAAG,eAAe,CAAC,OAAO,CAAC,CAAC;IAC7C,IAAM,UAAU,GAAG,WAAW,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC;IACrD,IAAM,OAAO,GAAG,YAAY,CAAC,UAAU,CAAC,CAAC;IACzC,cACE,KAAe;QAEf,OAAO,aAAa,CAAC,KAAK,EAAE,WAAkB,CAAC,CAAC;IAClD,CAAC;IACD;QACE,cAAc,CAAC,OAAO,CAAC,CAAC;QACxB,kBAAkB,CAAC,WAAW,CAAC,CAAC;IAClC,CAAC;IACD,OAAO,EAAC,OAAO,SAAA,EAAE,GAAG,EAAE,IAAI,EAAE,OAAO,EAAE,aAAa,EAAC,CAAC;AACtD,CAAC;AAED;;;;;;;;;;;;;;;;;;;;;;;;;;GA0BG;AACH,MAAM,cAGJ,IAAO,EAAE,OAAU;IACnB,IAAM,OAAO,GAAG,KAAK,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;IACrC,IACE,OAAO,MAAM,KAAK,WAAW;QAC5B,MAAc,CAAC,mCAAmC,EACnD;QACC,MAAc,CAAC,mCAAmC,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;KACpE;IACD,OAAO,OAAO,CAAC,GAAG,EAAE,CAAC;AACvB,CAAC;AAED,eAAe,GAAG,CAAC"}

lib/es6/internals.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"internals.js","sourceRoot":"","sources":["../../src/internals.ts"],"names":[],"mappings":"AAAA,OAAO,EAAY,MAAM,SAAS,CAAC;AACnC,OAAO,SAAS,MAAM,WAAW,CAAC;AAClC,OAAO,EAAC,KAAK,EAAC,MAAM,SAAS,CAAC;AAS9B,IAAM,iBAAiB,GAAG,SAAS,EAAE,CAAC;AAEtC,MAAM,UAAU,eAAe,CAAoB,OAAU;IAC3D,IAAM,WAAW,GAAmB,EAAoB,CAAC;IACzD,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IAAI,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC,EAAE;YAChC,WAAW,CAAC,MAAI,CAAC,GAAG,EAAE,CAAC,MAAM,EAAO,CAAC;SACtC;KACF;IACD,OAAO,WAAW,CAAC;AACrB,CAAC;AAED,MAAM,UAAU,WAAW,CACzB,OAAU,EACV,WAA2B;IAE3B,IAAM,OAAO,GAAe,EAAgB,CAAC;IAC7C,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IAAI,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC,EAAE;YAChC,OAAO,CAAC,MAAW,CAAC,GAAG,OAAO,CAAC,MAAI,CAAC,CAAC,WAAW,CAAC,MAAI,CAAC,EAAE,MAAI,CAAC,CAAC;YAC9D,IAAI,OAAO,CAAC,MAAW,CAAC,IAAI,OAAO,OAAO,CAAC,MAAW,CAAC,KAAK,QAAQ,EAAE;gBACnE,OAAO,CAAC,MAAW,CAA0B,CAAC,cAAc,GAAG,MAAI,CAAC;aACtE;SACF;KACF;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAED,oCAAoC;AACpC,MAAM,UAAU,YAAY,CAAK,OAAW;IAC1C,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IACE,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC;YAC5B,OAAO,CAAC,MAAI,CAAC;YACb,OAAS,OAAO,CAAC,MAAI,CAAyB,CAAC,kBAAkB;gBAC/D,UAAU,EACZ;YACA,OAAO,CAAC,MAAI,CAAC,GAAG,KAAK,CAAE,OAAO,CAAC,MAAI,CAAwB,CAAC,CAAC;SAC9D;KACF;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAyBD,MAAM,UAAU,aAAa,CAC3B,KAAS,EACT,WAA4B;IAE5B,IAAM,SAAS,GAAoB,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,MAAM,CAC1D,UAAA,IAAI,IAAI,OAAA,CAAC,CAAC,WAAW,CAAC,IAAI,CAAC,EAAnB,CAAmB,CAC5B,CAAC;IAEF,IAAI,OAAO,GAA2B,EAA4B,CAAC;IACnE,IAAM,WAAW,GAAwB,EAAyB,CAAC;IACnE,SAAS,CAAC,OAAO,CAAC,UAAA,IAAI;QACpB,OAAO,CAAC,IAAI,CAAC,GAAG,EAAC,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,EAAC,CAAC;QACjC,WAAW,CAAC,IAAI,CAAC,GAAG;YAClB,IAAI,EAAE,UAAC,CAAM,IAAK,OAAA,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,EAAxB,CAAwB;YAC1C,KAAK,EAAE,UAAC,GAAQ,IAAK,OAAA,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,EAA1B,CAA0B;YAC/C,QAAQ,EAAE,cAAO,CAAC;SACnB,CAAC;IACJ,CAAC,CAAC,CAAC;IAEH,IAAM,aAAa,GAAG,SAAS,CAAC,GAAG,CAAC,UAAA,IAAI;QACtC,OAAA,EAAE,CAAC,cAAc,CAAC,KAAK,CAAC,IAAI,CAAQ,CAAC,CAAC,SAAS,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;IAAlE,CAAkE,CACnE,CAAC;IAEF,SAAS,CAAC,OAAO,CAAC,UAAA,IAAI;QACpB,IAAM,QAAQ,GAAG,WAAW,CAAC,IAAI,CAAC,CAAC;QACnC,IAAM,IAAI,GAAG,UAAC,CAAM;YAClB,iBAAiB,CAAC,cAAM,OAAA,QAAQ,CAAC,EAAE,CAAC,CAAC,CAAC,EAAd,CAAc,CAAC,CAAC;QAC1C,CAAC,CAAC;QACF,IAAM,KAAK,GAAG,UAAC,GAAQ;YACrB,iBAAiB,CAAC;gBAChB,CAAC,OAAO,CAAC,KAAK,IAAI,OAAO,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,CAAC;gBACpC,QAAQ,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC;YACnB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;QACF,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC/B,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QAChC,WAAW,CAAC,IAAI,CAAC,CAAC,IAAI,GAAG,IAAI,CAAC;QAC9B,WAAW,CAAC,IAAI,CAAC,CAAC,KAAK,GAAG,KAAK,CAAC;QAChC,mEAAmE;QACnE,yCAAyC;QACzC,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,IAAI,CAAC;QAC5B,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,KAAK,CAAC;IAC/B,CAAC,CAAC,CAAC;IACH,OAAO,GAAG,IAAW,CAAC,CAAC,iBAAiB;IAExC,OAAO,SAAS,kBAAkB;QAChC,aAAa,CAAC,OAAO,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,CAAC,WAAW,EAAE,EAAf,CAAe,CAAC,CAAC;IAC9C,CAAC,CAAC;AACJ,CAAC;AAED,MAAM,UAAU,kBAAkB,CAAK,WAA4B;IACjE,MAAM,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC,OAAO,CAAC,UAAA,IAAI,IAAI,OAAA,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,EAAE,EAAtB,CAAsB,CAAC,CAAC;AACnE,CAAC;AAED,MAAM,UAAU,cAAc,CAAK,OAAW;IAC5C,KAAK,IAAM,CAAC,IAAI,OAAO,EAAE;QACvB,IACE,OAAO,CAAC,cAAc,CAAC,CAAC,CAAC;YACzB,OAAO,CAAC,CAAC,CAAC;YACT,OAAO,CAAC,CAAC,CAAS,CAAC,OAAO,EAC3B;YACC,OAAO,CAAC,CAAC,CAAS,CAAC,OAAO,EAAE,CAAC;SAC/B;KACF;AACH,CAAC;AAED,MAAM,UAAU,aAAa,CAAC,GAAQ;IACpC,OAAO,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,MAAM,KAAK,CAAC,CAAC;AACvC,CAAC"}
+{"version":3,"file":"internals.js","sourceRoot":"","sources":["../../src/internals.ts"],"names":[],"mappings":"AAAA,OAAO,EAAY,MAAM,SAAS,CAAC;AACnC,OAAO,SAAS,MAAM,WAAW,CAAC;AAClC,OAAO,EAAC,KAAK,EAAC,MAAM,SAAS,CAAC;AAS9B,IAAM,iBAAiB,GAAG,SAAS,EAAE,CAAC;AAEtC,MAAM,0BAA6C,OAAU;IAC3D,IAAM,WAAW,GAAmB,EAAoB,CAAC;IACzD,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IAAI,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC,EAAE;YAChC,WAAW,CAAC,MAAI,CAAC,GAAG,EAAE,CAAC,MAAM,EAAO,CAAC;SACtC;KACF;IACD,OAAO,WAAW,CAAC;AACrB,CAAC;AAED,MAAM,sBACJ,OAAU,EACV,WAA2B;IAE3B,IAAM,OAAO,GAAe,EAAgB,CAAC;IAC7C,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IAAI,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC,EAAE;YAChC,OAAO,CAAC,MAAW,CAAC,GAAG,OAAO,CAAC,MAAI,CAAC,CAAC,WAAW,CAAC,MAAI,CAAC,EAAE,MAAI,CAAC,CAAC;YAC9D,IAAI,OAAO,CAAC,MAAW,CAAC,IAAI,OAAO,OAAO,CAAC,MAAW,CAAC,KAAK,QAAQ,EAAE;gBACnE,OAAO,CAAC,MAAW,CAA0B,CAAC,cAAc,GAAG,MAAI,CAAC;aACtE;SACF;KACF;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAED,oCAAoC;AACpC,MAAM,uBAA2B,OAAW;IAC1C,KAAK,IAAM,MAAI,IAAI,OAAO,EAAE;QAC1B,IACE,OAAO,CAAC,cAAc,CAAC,MAAI,CAAC;YAC5B,OAAO,CAAC,MAAI,CAAC;YACb,OAAS,OAAO,CAAC,MAAI,CAAyB,CAAC,kBAAkB;gBAC/D,UAAU,EACZ;YACA,OAAO,CAAC,MAAI,CAAC,GAAG,KAAK,CAAE,OAAO,CAAC,MAAI,CAAwB,CAAC,CAAC;SAC9D;KACF;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAyBD,MAAM,wBACJ,KAAS,EACT,WAA4B;IAE5B,IAAM,SAAS,GAAoB,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,MAAM,CAC1D,UAAA,IAAI,IAAI,OAAA,CAAC,CAAC,WAAW,CAAC,IAAI,CAAC,EAAnB,CAAmB,CAC5B,CAAC;IAEF,IAAI,OAAO,GAA2B,EAA4B,CAAC;IACnE,IAAM,WAAW,GAAwB,EAAyB,CAAC;IACnE,SAAS,CAAC,OAAO,CAAC,UAAA,IAAI;QACpB,OAAO,CAAC,IAAI,CAAC,GAAG,EAAC,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,EAAC,CAAC;QACjC,WAAW,CAAC,IAAI,CAAC,GAAG;YAClB,IAAI,EAAE,UAAC,CAAM,IAAK,OAAA,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,EAAxB,CAAwB;YAC1C,KAAK,EAAE,UAAC,GAAQ,IAAK,OAAA,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,GAAG,CAAC,EAA1B,CAA0B;YAC/C,QAAQ,EAAE,cAAO,CAAC;SACnB,CAAC;IACJ,CAAC,CAAC,CAAC;IAEH,IAAM,aAAa,GAAG,SAAS,CAAC,GAAG,CAAC,UAAA,IAAI;QACtC,OAAA,EAAE,CAAC,cAAc,CAAC,KAAK,CAAC,IAAI,CAAQ,CAAC,CAAC,SAAS,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;IAAlE,CAAkE,CACnE,CAAC;IAEF,SAAS,CAAC,OAAO,CAAC,UAAA,IAAI;QACpB,IAAM,QAAQ,GAAG,WAAW,CAAC,IAAI,CAAC,CAAC;QACnC,IAAM,IAAI,GAAG,UAAC,CAAM;YAClB,iBAAiB,CAAC,cAAM,OAAA,QAAQ,CAAC,EAAE,CAAC,CAAC,CAAC,EAAd,CAAc,CAAC,CAAC;QAC1C,CAAC,CAAC;QACF,IAAM,KAAK,GAAG,UAAC,GAAQ;YACrB,iBAAiB,CAAC;gBAChB,CAAC,OAAO,CAAC,KAAK,IAAI,OAAO,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,CAAC;gBACpC,QAAQ,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC;YACnB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;QACF,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC/B,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QAChC,WAAW,CAAC,IAAI,CAAC,CAAC,IAAI,GAAG,IAAI,CAAC;QAC9B,WAAW,CAAC,IAAI,CAAC,CAAC,KAAK,GAAG,KAAK,CAAC;QAChC,mEAAmE;QACnE,yCAAyC;QACzC,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,IAAI,CAAC;QAC5B,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,KAAK,CAAC;IAC/B,CAAC,CAAC,CAAC;IACH,OAAO,GAAG,IAAW,CAAC,CAAC,iBAAiB;IAExC,OAAO;QACL,aAAa,CAAC,OAAO,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,CAAC,WAAW,EAAE,EAAf,CAAe,CAAC,CAAC;IAC9C,CAAC,CAAC;AACJ,CAAC;AAED,MAAM,6BAAiC,WAA4B;IACjE,MAAM,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC,OAAO,CAAC,UAAA,IAAI,IAAI,OAAA,WAAW,CAAC,IAAI,CAAC,CAAC,EAAE,EAAE,EAAtB,CAAsB,CAAC,CAAC;AACnE,CAAC;AAED,MAAM,yBAA6B,OAAW;IAC5C,KAAK,IAAM,CAAC,IAAI,OAAO,EAAE;QACvB,IACE,OAAO,CAAC,cAAc,CAAC,CAAC,CAAC;YACzB,OAAO,CAAC,CAAC,CAAC;YACT,OAAO,CAAC,CAAC,CAAS,CAAC,OAAO,EAC3B;YACC,OAAO,CAAC,CAAC,CAAS,CAAC,OAAO,EAAE,CAAC;SAC/B;KACF;AACH,CAAC;AAED,MAAM,wBAAwB,GAAQ;IACpC,OAAO,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,MAAM,KAAK,CAAC,CAAC;AACvC,CAAC"}

lib/es6/types.d.ts

@@ -24,3 +24,3 @@ import { Stream } from 'xstream';
 export declare type Drivers = {
-    [name: string]: Driver<FantasyObservable | undefined | void | null, any>;
+    [name: string]: Driver<Stream<any> | void, any | void>;
 };
@@ -31,5 +31,3 @@ export declare type Main = (...args: Array<any>) => any;
 };
-export declare type Sinks<M extends Main> = {
-    [k in (string & keyof ReturnType<M>)]: ReturnType<M>[k] & FantasyObservable;
-};
+export declare type Sinks<M extends Main> = ReturnType<M>;
 export declare type MatchingMain<D extends Drivers, M extends Main> = Main & {
@@ -39,3 +37,3 @@ (so?: Partial<Sources<D>>): Sinks<M>;
 export declare type MatchingDrivers<D extends Drivers, M extends Main> = Drivers & {
-    [k in (string & keyof Sinks<M>)]: ((si?: Sinks<M>[k]) => Sources<D>[k]) | ((si: Sinks<M>[k]) => Sources<D>[k]);
+    [k in string & keyof Sinks<M>]: ((si?: Sinks<M>[k]) => Sources<D>[k]) | ((si: Sinks<M>[k]) => Sources<D>[k]);
 };
@@ -42,0 +40,0 @@ export interface CycleProgram<D extends MatchingDrivers<D, M>, M extends MatchingMain<D, M>> {

package.json

 {
   "name": "@cycle/run",
-  "version": "5.0.0",
+  "version": "5.1.0-rc.0",
   "description": "The Cycle.js run() function to use with xstream",
@@ -5,0 +5,0 @@ "license": "MIT",

src/types.ts

@@ -30,3 +30,3 @@ import {Stream} from 'xstream';
 export type Drivers = {
-  [name: string]: Driver<FantasyObservable | undefined | void | null, any>;
+  [name: string]: Driver<Stream<any> | void, any | void>;
 };
@@ -38,5 +38,3 @@
 
-export type Sinks<M extends Main> = {
-  [k in (string & keyof ReturnType<M>)]: ReturnType<M>[k] & FantasyObservable
-};
+export type Sinks<M extends Main> = ReturnType<M>;
 
@@ -49,3 +47,3 @@ export type MatchingMain<D extends Drivers, M extends Main> = Main & {
   {
-    [k in (string & keyof Sinks<M>)]:
+    [k in string & keyof Sinks<M>]:
       | ((si?: Sinks<M>[k]) => Sources<D>[k])
@@ -52,0 +50,0 @@ | ((si: Sinks<M>[k]) => Sources<D>[k])

New alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

107935

3.65%

Number of package files

46

15%

Lines of code

2068

4.39%

Worsened metrics

Number of low quality alerts

1

Infinity%

No dependency changes