Comparing version 1.4.3 to 1.4.4
@@ -677,15 +677,12 @@ function pipe(source) { | ||
return function(sink) { | ||
var teardown = f([ | ||
function(value) { | ||
return sink(__(1, [value])); | ||
}, | ||
function(param) { | ||
return sink(0); | ||
var teardown = [ | ||
function() { | ||
return 0; | ||
} | ||
]); | ||
return sink( | ||
]; | ||
sink( | ||
__(0, [ | ||
function(signal) { | ||
if (signal) { | ||
return teardown(); | ||
return teardown[0](); | ||
} else { | ||
@@ -697,2 +694,11 @@ return 0; | ||
); | ||
teardown[0] = f([ | ||
function(value) { | ||
return sink(__(1, [value])); | ||
}, | ||
function(param) { | ||
return sink(0); | ||
} | ||
]); | ||
return 0; | ||
}; | ||
@@ -699,0 +705,0 @@ }; |
@@ -665,15 +665,12 @@ function __(tag, block) { | ||
return function(sink) { | ||
var teardown = f([ | ||
function(value) { | ||
return sink(__(1, [value])); | ||
}, | ||
function(param) { | ||
return sink(0); | ||
var teardown = [ | ||
function() { | ||
return 0; | ||
} | ||
]); | ||
return sink( | ||
]; | ||
sink( | ||
__(0, [ | ||
function(signal) { | ||
if (signal) { | ||
return teardown(); | ||
return teardown[0](); | ||
} else { | ||
@@ -685,2 +682,11 @@ return 0; | ||
); | ||
teardown[0] = f([ | ||
function(value) { | ||
return sink(__(1, [value])); | ||
}, | ||
function(param) { | ||
return sink(0); | ||
} | ||
]); | ||
return 0; | ||
}; | ||
@@ -687,0 +693,0 @@ }; |
@@ -7,3 +7,13 @@ 'use strict'; | ||
return (function (sink) { | ||
var teardown = f(/* record */[ | ||
var teardown = /* record */[/* contents */(function () { | ||
return /* () */0; | ||
})]; | ||
sink(/* Start */Block.__(0, [(function (signal) { | ||
if (signal) { | ||
return teardown[0](); | ||
} else { | ||
return /* () */0; | ||
} | ||
})])); | ||
teardown[0] = f(/* record */[ | ||
/* next */(function (value) { | ||
@@ -16,9 +26,3 @@ return sink(/* Push */Block.__(1, [value])); | ||
]); | ||
return sink(/* Start */Block.__(0, [(function (signal) { | ||
if (signal) { | ||
return teardown(); | ||
} else { | ||
return /* () */0; | ||
} | ||
})])); | ||
return /* () */0; | ||
}); | ||
@@ -25,0 +29,0 @@ } |
{ | ||
"name": "wonka", | ||
"version": "1.4.3", | ||
"version": "1.4.4", | ||
"author": "Phil Pluckthun <phil@kitten.sh>", | ||
@@ -5,0 +5,0 @@ "source": "./src/index.js", |
@@ -7,3 +7,13 @@ | ||
return (function (sink) { | ||
var teardown = f(/* record */[ | ||
var teardown = /* record */[/* contents */(function () { | ||
return /* () */0; | ||
})]; | ||
sink(/* Start */Block.__(0, [(function (signal) { | ||
if (signal) { | ||
return teardown[0](); | ||
} else { | ||
return /* () */0; | ||
} | ||
})])); | ||
teardown[0] = f(/* record */[ | ||
/* next */(function (value) { | ||
@@ -16,9 +26,3 @@ return sink(/* Push */Block.__(1, [value])); | ||
]); | ||
return sink(/* Start */Block.__(0, [(function (signal) { | ||
if (signal) { | ||
return teardown(); | ||
} else { | ||
return /* () */0; | ||
} | ||
})])); | ||
return /* () */0; | ||
}); | ||
@@ -25,0 +29,0 @@ } |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
387746
8858