kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-05 01:45:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Watch properties cancel long poll requests

Browse Source
This commit is contained in:
Michael Lange
2018-02-14 15:41:07 -08:00
parent ed809fe27e
commit b69fe312b8
1 changed files with 17 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
ui/app/utils/properties/watch.js
View File

@@ -18,27 +18,35 @@ export function watchRecord(modelName) {
} catch (e) {
yield e;
break;
} finally {
this.get('store')
.adapterFor(modelName)
.cancelFindRecord(modelName, id);
}
}
});
}).drop();
}
export function watchRelationship(staticRelationshipName) {
export function watchRelationship(relationshipName) {
return task(function*(model, throttle = 2000) {
while (true) {
try {
yield RSVP.all([
this.get('store')
.adapterFor(model.constructor.modelName)
.reloadRelationship(model, staticRelationshipName, true),
.reloadRelationship(model, relationshipName, true),
wait(throttle),
]);
} catch (e) {
yield e;
break;
} finally {
this.get('store')
.adapterFor(model.constructor.name)
.cancelReloadRelationship(model, relationshipName);
}
}
});
}).drop();
}
export function watchAll(modelName) {
@@ -52,7 +60,11 @@ export function watchAll(modelName) {
} catch (e) {
yield e;
break;
} finally {
this.get('store')
.adapterFor(modelName)
.cancelFindAll(modelName);
}
}
});
}).drop();
}