maxmustermann/kibana
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[courier/fetch] detect aborted requests more agressively

Browse source
This commit is contained in:
spalger 2016-03-24 14:35:46 -07:00
parent 8a4992640b
commit c12f18df27
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/ui/public/courier/fetch/fetch_these.js
View file

@ -29,22 +29,26 @@ export default function FetchTheseProvider(Private, Promise) {
} }
function fetchWithStrategy(strategy, requests) { function fetchWithStrategy(strategy, requests) {
function replaceAbortedRequests() {
requests = requests.map(r => r.aborted ? ABORTED : r);
}
requests = requests.map(function (req) { replaceAbortedRequests();
return req.aborted ? ABORTED : req;
});
return startRequests(requests) return startRequests(requests)
.then(function () { .then(function () {
replaceAbortedRequests();
return callClient(strategy, requests); return callClient(strategy, requests);
}) })
.then(function (responses) { .then(function (responses) {
replaceAbortedRequests();
return callResponseHandlers(requests, responses); return callResponseHandlers(requests, responses);
}) })
.then(function (responses) { .then(function (responses) {
replaceAbortedRequests();
return continueIncomplete(strategy, requests, responses, fetchWithStrategy); return continueIncomplete(strategy, requests, responses, fetchWithStrategy);
}) })
.then(function (responses) { .then(function (responses) {
replaceAbortedRequests();
return responses.map(function (resp) { return responses.map(function (resp) {
switch (resp) { switch (resp) {
case ABORTED: case ABORTED: