alex/yomichan
1
Fork 0
Code Releases Activity

Async pooling

Browse Source
This commit is contained in:
Alex Yatskov 2016-05-06 21:34:06 -07:00
parent f7db707dc2
commit 7015b80469
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ext/bg/js/yomichan.js
View File

@ -34,6 +34,7 @@ class Yomichan {
}); });
this.translator = new Translator(); this.translator = new Translator();
this.asyncPools = {};
this.setState('disabled'); this.setState('disabled');
loadOptions((opts) => { loadOptions((opts) => {
@ -50,7 +51,7 @@ class Yomichan {
onMessage(request, sender, callback) { onMessage(request, sender, callback) {
const {action, params} = request, handlers = { const {action, params} = request, handlers = {
canAddNotes: (definitions) => this.ankiInvoke('canAddNotes', definitions, callback), canAddNotes: (definitions) => this.ankiInvoke('canAddNotes', definitions, 'notes', callback),
findKanji: (text) => callback(this.translator.findKanji(text)), findKanji: (text) => callback(this.translator.findKanji(text)),
findTerm: (text) => callback(this.translator.findTerm(text)), findTerm: (text) => callback(this.translator.findTerm(text)),
getOptions: () => callback(this.options), getOptions: () => callback(this.options),
@ -101,10 +102,17 @@ class Yomichan {
Yomichan.notifyChange('options', this.options); Yomichan.notifyChange('options', this.options);
} }
ankiInvoke(action, params, callback) { ankiInvoke(action, params, pool, callback) {
if (this.options.enableAnkiConnect) { if (pool !== null && this.asyncPools.hasOwnProperty(pool)) {
this.asyncPools[pool].abort();
callback(null);
} else if (this.options.enableAnkiConnect) {
const xhr = new XMLHttpRequest(); const xhr = new XMLHttpRequest();
xhr.addEventListener('loadend', () => { xhr.addEventListener('loadend', () => {
if (pool !== null) {
delete this.asyncPools[pool];
}
const resp = xhr.responseText; const resp = xhr.responseText;
callback(resp ? JSON.parse(resp) : null); callback(resp ? JSON.parse(resp) : null);
}); });