aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSam Wilkins <samwilkins333@gmail.com>2019-09-14 03:05:37 -0400
committerSam Wilkins <samwilkins333@gmail.com>2019-09-14 03:05:37 -0400
commit57d6b3da9a918e90d6472c11bac01166e4020185 (patch)
treeffc62f1a1cec309f78bad504a362b3663dbd9e65 /src
parentfc81c0f8ab727ad959eb6b416aff9c190e306adb (diff)
fixed batching
Diffstat (limited to 'src')
-rw-r--r--src/client/util/UtilExtensions.ts42
-rw-r--r--src/server/credentials/google_docs_token.json2
2 files changed, 24 insertions, 20 deletions
diff --git a/src/client/util/UtilExtensions.ts b/src/client/util/UtilExtensions.ts
index 3eeec6ca7..eca10c3b1 100644
--- a/src/client/util/UtilExtensions.ts
+++ b/src/client/util/UtilExtensions.ts
@@ -52,20 +52,22 @@ module.exports.ExecuteInBatchesAtInterval = async function <I>(batchSize: number
return;
}
const batches = this.batch(batchSize);
- return new Promise<void>(resolve => {
+ return new Promise<void>(async resolve => {
const iterator = batches[Symbol.iterator]();
let completed = 0;
- const tag = setInterval(async () => {
+ while (true) {
const next = iterator.next();
- if (next.done) {
- clearInterval(tag);
- } else {
- await handler(next.value);
- if (++completed === batches.length) {
+ await new Promise<void>(resolve => {
+ setTimeout(async () => {
+ await handler(next.value);
resolve();
- }
+ }, interval * 1000);
+ });
+ if (++completed === batches.length) {
+ break;
}
- }, interval * 1000);
+ }
+ resolve();
});
};
@@ -75,19 +77,21 @@ module.exports.ConvertInBatchesAtInterval = async function <I, O>(batchSize: num
}
let collector: O[] = [];
const batches = this.batch(batchSize);
- return new Promise<O[]>(resolve => {
+ return new Promise<O[]>(async resolve => {
const iterator = batches[Symbol.iterator]();
let completed = 0;
- const tag = setInterval(async () => {
+ while (true) {
const next = iterator.next();
- if (next.done) {
- clearInterval(tag);
- } else {
- collector.push(...(await handler(next.value)));
- if (++completed === batches.length) {
- resolve(collector);
- }
+ await new Promise<void>(resolve => {
+ setTimeout(async () => {
+ collector.push(...(await handler(next.value)));
+ resolve();
+ }, interval * 1000);
+ });
+ if (++completed === batches.length) {
+ resolve(collector);
+ break;
}
- }, interval * 1000);
+ }
});
}; \ No newline at end of file
diff --git a/src/server/credentials/google_docs_token.json b/src/server/credentials/google_docs_token.json
index 05d0aa53b..bb8e1d817 100644
--- a/src/server/credentials/google_docs_token.json
+++ b/src/server/credentials/google_docs_token.json
@@ -1 +1 @@
-{"access_token":"ya29.GlyDB1Mzjd6_AtAPWPSL1oUWGpmrknNNsJGki6iXlMOJGRbWPQ08dOD3tC2DYlSJN2JgTsMlfAIpjZZ9to3conAdAubgnKfLi7XiHCe5QPcw_G65oSS4E5g9XyuloA","refresh_token":"1/HTv_xFHszu2Nf3iiFrUTaeKzC_Vp2-6bpIB06xW_WHI","scope":"https://www.googleapis.com/auth/presentations.readonly https://www.googleapis.com/auth/documents.readonly https://www.googleapis.com/auth/drive.file https://www.googleapis.com/auth/documents https://www.googleapis.com/auth/photoslibrary https://www.googleapis.com/auth/photoslibrary.appendonly https://www.googleapis.com/auth/drive https://www.googleapis.com/auth/presentations https://www.googleapis.com/auth/photoslibrary.sharing","token_type":"Bearer","expiry_date":1568432027550} \ No newline at end of file
+{"access_token":"ya29.ImCDBxXGjYmUr-TU0k1J9B4MSb6dZEvaDi7jXAZxV3EESxYIHmPbrbCSTHRi-8DXFwKOS-x6NRE5HZ3x5hv6qpWbkPVg0-_wLjBOVdBH4YiIRUgOEKicR_tFL5LxzboL-0M","refresh_token":"1/HTv_xFHszu2Nf3iiFrUTaeKzC_Vp2-6bpIB06xW_WHI","scope":"https://www.googleapis.com/auth/presentations.readonly https://www.googleapis.com/auth/documents.readonly https://www.googleapis.com/auth/drive.file https://www.googleapis.com/auth/documents https://www.googleapis.com/auth/photoslibrary https://www.googleapis.com/auth/photoslibrary.appendonly https://www.googleapis.com/auth/drive https://www.googleapis.com/auth/presentations https://www.googleapis.com/auth/photoslibrary.sharing","token_type":"Bearer","expiry_date":1568444910512} \ No newline at end of file