ben/brouter-web
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

abort pending requests from previous rerouteAllSegments (empty queue)

Browse source
This commit is contained in:
Norbert Renner 2014-08-20 16:03:01 +02:00
parent 9ec5985b2c
commit 59d4acc3c6
2 changed files with 20 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

9
js/index.js
View file

@ -97,6 +97,11 @@
function updateRoute(evt) {
router.setOptions(evt.options);
// abort pending requests from previous rerouteAllSegments
if (!router.queue.idle()) {
router.queue.kill();
}
routing.rerouteAllSegments(onUpdate);
}
@ -156,7 +161,9 @@
function onUpdate(err) {
if (err) {
BR.message.showError(err);
if (err !== L.BRouter.ABORTED_ERROR) {
BR.message.showError(err);
}
return;
} else {
BR.message.hideError();

13
js/router/BRouter.js
View file

@ -5,7 +5,8 @@ L.BRouter = L.Class.extend({
URL_PROFILE_UPLOAD: BR.conf.host + '/brouter/profile',
PRECISION: 6,
NUMBER_SEPARATOR: ',',
GROUP_SEPARATOR: '|'
GROUP_SEPARATOR: '|',
ABORTED_ERROR: 'aborted'
},
options: {
@ -18,6 +19,16 @@ L.BRouter = L.Class.extend({
this.queue = async.queue(L.bind(function (task, callback) {
this.getRoute(task.segment, callback);
}, this), 1);
// patch to call callbacks on kill for cleanup (loadingTrailer)
this.queue.kill = function () {
var aborted = this.tasks;
this.drain = null;
this.tasks = [];
aborted.forEach(function(task) {
task.callback(L.BRouter.ABORTED_ERROR);
});
};
},
setOptions: function(options) {