"use strict";
|
|
Object.defineProperty(exports, "__esModule", {
|
value: true
|
});
|
exports.forwardAsync = forwardAsync;
|
exports.isAsync = void 0;
|
exports.isThenable = isThenable;
|
exports.maybeAsync = maybeAsync;
|
exports.waitFor = exports.onFirstPause = void 0;
|
|
function _gensync() {
|
const data = require("gensync");
|
|
_gensync = function () {
|
return data;
|
};
|
|
return data;
|
}
|
|
const id = x => x;
|
|
const runGenerator = _gensync()(function* (item) {
|
return yield* item;
|
});
|
|
const isAsync = _gensync()({
|
sync: () => false,
|
errback: cb => cb(null, true)
|
});
|
|
exports.isAsync = isAsync;
|
|
function maybeAsync(fn, message) {
|
return _gensync()({
|
sync(...args) {
|
const result = fn.apply(this, args);
|
if (isThenable(result)) throw new Error(message);
|
return result;
|
},
|
|
async(...args) {
|
return Promise.resolve(fn.apply(this, args));
|
}
|
|
});
|
}
|
|
const withKind = _gensync()({
|
sync: cb => cb("sync"),
|
async: cb => cb("async")
|
});
|
|
function forwardAsync(action, cb) {
|
const g = _gensync()(action);
|
|
return withKind(kind => {
|
const adapted = g[kind];
|
return cb(adapted);
|
});
|
}
|
|
const onFirstPause = _gensync()({
|
name: "onFirstPause",
|
arity: 2,
|
sync: function (item) {
|
return runGenerator.sync(item);
|
},
|
errback: function (item, firstPause, cb) {
|
let completed = false;
|
runGenerator.errback(item, (err, value) => {
|
completed = true;
|
cb(err, value);
|
});
|
|
if (!completed) {
|
firstPause();
|
}
|
}
|
});
|
|
exports.onFirstPause = onFirstPause;
|
|
const waitFor = _gensync()({
|
sync: id,
|
async: id
|
});
|
|
exports.waitFor = waitFor;
|
|
function isThenable(val) {
|
return !!val && (typeof val === "object" || typeof val === "function") && !!val.then && typeof val.then === "function";
|
}
|
