如何等待蓝鸟承诺在多个地点落户?
How to wait for a bluebird promise to settle in multiple locations?
我遇到这样一种情况,一堆函数需要等待一个 promise 来解决,因为它是 init 函数;
self.init=new Promise(function(resolve){
//do stuff, take awhile
resolve();
});
但是,在初始化时,异步性质意味着正在调用依赖于初始化的其他函数。我希望这些函数等待 init 完成,然后继续。
我尝试在每个函数中这样做
function doSomethingUseful(){
self.init.reflect().then(function () {
//do functions purpose
});
}
function doSomethingUseless(){
self.init.reflect().then(function () {
//do functions purpose
});
}
但它只是随机工作,可能只有在 init 已经解决时才工作,如果没有,它就挂在这里,奇怪地挂起整个应用程序,尽管它是异步的。
我正在尝试替换以前的解决方案,该解决方案涉及间隔并在每个函数调用中检查布尔 isInit。
有没有蓝鸟函数可以做到这一点?还是另一种继续等待并检查承诺以查看其是否已解决的方法?
该应用在很多地方都有这种结构。通常围绕 sqlite read/writes。打开数据库的 init,但在打开时,页面正在加载并且它已经在尝试 read/write 到表,因此那些 read/writes 被迫等待使用 setInterval 并反复检查是否初始化已完成。
这是一个使用 google 分析的示例。
function Analytics() {
var self = this;
self.ready = ko.observable(false).subscribeTo('application:ready'); //attached to page ready event in jquerymobile and cordova
self.trackerInit = new Promise(function (resolve, reject) {
ko.computed(function () {
if (self.ready()) {
window.ga.startTrackerWithId('id', 1000, resolve, reject);
}
});
});
}
Analytics.prototype.trackSpeed = function (cat, interval, variable, label) {
var self = this;
console.log("speed tracker", cat, interval, variable, label); //this logs
return self.trackerInit.then(function () {
console.log("speed tracker confirm init"); //this never logs, all execution stops including other async code
return new Promise(function (resolve, reject) {
window.ga.trackTiming(cat, interval, variable, label, resolve, reject);
});
}).catch(function (e) {
if (e.message === "send timeout") {
return true; //who cares about timeouts anyways
} else {
throw e;//rethrow it
}
});
};
在没有 return 的页面更改事件中调用函数,纯异步。调用它会导致所有执行停止。
准备好的劫是这样完成的
self.ready = ko.observable(false).publishOn('application:ready');
var deviceReady = new Promise(function (resolve) {
$(document).on('deviceready', resolve);
});
var pageReady = new Promise(function (resolve) {
$(document).on('pagecreate', resolve);
});
Promise.all([deviceReady, pageReady]).then(function () {
//a couple of page of code and...
self.ready(true);
});
像这样更改 init 在检查结果时会产生相同的挂起结果
self.trackerInit = new Promise(function (resolve, reject) {
console.log("initting");
checker = setInterval(function () {
if (window.ga) {
console.log("ready init");
window.ga.startTrackerWithId('id', 100, function(){
clearInterval(checker);
console.log("init complete");
resolve();
}, reject);
}
}, 1000);
});
它们只是承诺。只需使用 then
链接它们
function doSomethingUseful() {
// wait for init to finish, then do our stuff
// return the new chained promise in case someone wants to wait on us
return self.init.then(function () {
// do stuff
});
}
function doSomethingUseless() {
// wait for init to finish, then do our stuff
// return the new chained promise in case someone wants to wait on us
return self.init.then(function () {
// do stuff
});
}
// do both of those things and then do something else!
Promise.all([doSomethingUseful(), doSomethingUseless()]).then(function () {
console.log("init is done. And we've done something useful and useless.")
}
编辑:
根据您的附加代码,问题是如果应用程序是 "ready" 在您的 Analytics 组件构建之前,那么您将永远不会收到 "application:ready"(因为它是在您订阅之前出现的)所以你的 "ready" observable 将保持错误。根据邮箱文档,您需要将 true
作为第二个参数传递给 subscribeTo
,这样即使它发生在过去,您也可以获得就绪值:
ko.observable(false).subscribeTo("application:ready", true)
但是,构建所有这些可观察值和计算值只是为了提供一个 promise 是矫枉过正的。怎么样:
self.trackerInit = new Promise(function (resolve, reject) {
const s = ko.postbox.subscribe("application:ready", function (value) {
if (value) {
s.dispose(); // stop listening (prevent memory leak
window.ga.startTrackerWithId('id', 1000, resolve, reject);
}
}, true);
});
你甚至可以把它变成一个 promise 助手:
function whenReady(eventName) {
return new Promise((resolve, reject) => {
const s = ko.postbox.subscribe(eventName, value => {
if (ready) {
s.dispose();
resolve(value);
}
}, true);
});
}
function startGaTracker(id, timeout) {
return new Promise((resolve, reject) => window.ga.startTrackerWithId(id, timeout, resolve, reject);
}
那你可以这样写:
self.trackerInit = whenReady("application:ready")
.then(() => startGaTracker("id", 100));
我遇到这样一种情况,一堆函数需要等待一个 promise 来解决,因为它是 init 函数;
self.init=new Promise(function(resolve){
//do stuff, take awhile
resolve();
});
但是,在初始化时,异步性质意味着正在调用依赖于初始化的其他函数。我希望这些函数等待 init 完成,然后继续。
我尝试在每个函数中这样做
function doSomethingUseful(){
self.init.reflect().then(function () {
//do functions purpose
});
}
function doSomethingUseless(){
self.init.reflect().then(function () {
//do functions purpose
});
}
但它只是随机工作,可能只有在 init 已经解决时才工作,如果没有,它就挂在这里,奇怪地挂起整个应用程序,尽管它是异步的。
我正在尝试替换以前的解决方案,该解决方案涉及间隔并在每个函数调用中检查布尔 isInit。
有没有蓝鸟函数可以做到这一点?还是另一种继续等待并检查承诺以查看其是否已解决的方法?
该应用在很多地方都有这种结构。通常围绕 sqlite read/writes。打开数据库的 init,但在打开时,页面正在加载并且它已经在尝试 read/write 到表,因此那些 read/writes 被迫等待使用 setInterval 并反复检查是否初始化已完成。
这是一个使用 google 分析的示例。
function Analytics() {
var self = this;
self.ready = ko.observable(false).subscribeTo('application:ready'); //attached to page ready event in jquerymobile and cordova
self.trackerInit = new Promise(function (resolve, reject) {
ko.computed(function () {
if (self.ready()) {
window.ga.startTrackerWithId('id', 1000, resolve, reject);
}
});
});
}
Analytics.prototype.trackSpeed = function (cat, interval, variable, label) {
var self = this;
console.log("speed tracker", cat, interval, variable, label); //this logs
return self.trackerInit.then(function () {
console.log("speed tracker confirm init"); //this never logs, all execution stops including other async code
return new Promise(function (resolve, reject) {
window.ga.trackTiming(cat, interval, variable, label, resolve, reject);
});
}).catch(function (e) {
if (e.message === "send timeout") {
return true; //who cares about timeouts anyways
} else {
throw e;//rethrow it
}
});
};
在没有 return 的页面更改事件中调用函数,纯异步。调用它会导致所有执行停止。
准备好的劫是这样完成的
self.ready = ko.observable(false).publishOn('application:ready');
var deviceReady = new Promise(function (resolve) {
$(document).on('deviceready', resolve);
});
var pageReady = new Promise(function (resolve) {
$(document).on('pagecreate', resolve);
});
Promise.all([deviceReady, pageReady]).then(function () {
//a couple of page of code and...
self.ready(true);
});
像这样更改 init 在检查结果时会产生相同的挂起结果
self.trackerInit = new Promise(function (resolve, reject) {
console.log("initting");
checker = setInterval(function () {
if (window.ga) {
console.log("ready init");
window.ga.startTrackerWithId('id', 100, function(){
clearInterval(checker);
console.log("init complete");
resolve();
}, reject);
}
}, 1000);
});
它们只是承诺。只需使用 then
链接它们
function doSomethingUseful() {
// wait for init to finish, then do our stuff
// return the new chained promise in case someone wants to wait on us
return self.init.then(function () {
// do stuff
});
}
function doSomethingUseless() {
// wait for init to finish, then do our stuff
// return the new chained promise in case someone wants to wait on us
return self.init.then(function () {
// do stuff
});
}
// do both of those things and then do something else!
Promise.all([doSomethingUseful(), doSomethingUseless()]).then(function () {
console.log("init is done. And we've done something useful and useless.")
}
编辑:
根据您的附加代码,问题是如果应用程序是 "ready" 在您的 Analytics 组件构建之前,那么您将永远不会收到 "application:ready"(因为它是在您订阅之前出现的)所以你的 "ready" observable 将保持错误。根据邮箱文档,您需要将 true
作为第二个参数传递给 subscribeTo
,这样即使它发生在过去,您也可以获得就绪值:
ko.observable(false).subscribeTo("application:ready", true)
但是,构建所有这些可观察值和计算值只是为了提供一个 promise 是矫枉过正的。怎么样:
self.trackerInit = new Promise(function (resolve, reject) {
const s = ko.postbox.subscribe("application:ready", function (value) {
if (value) {
s.dispose(); // stop listening (prevent memory leak
window.ga.startTrackerWithId('id', 1000, resolve, reject);
}
}, true);
});
你甚至可以把它变成一个 promise 助手:
function whenReady(eventName) {
return new Promise((resolve, reject) => {
const s = ko.postbox.subscribe(eventName, value => {
if (ready) {
s.dispose();
resolve(value);
}
}, true);
});
}
function startGaTracker(id, timeout) {
return new Promise((resolve, reject) => window.ga.startTrackerWithId(id, timeout, resolve, reject);
}
那你可以这样写:
self.trackerInit = whenReady("application:ready")
.then(() => startGaTracker("id", 100));