aboutsummaryrefslogtreecommitdiff
path: root/src/server/index.ts
diff options
context:
space:
mode:
authorSam Wilkins <samwilkins333@gmail.com>2019-09-21 14:27:10 -0400
committerSam Wilkins <samwilkins333@gmail.com>2019-09-21 14:27:10 -0400
commitf529d7d22162689c08830418da67a89778111e16 (patch)
tree5ad0ede9cbbfbcae3ea7c850ab0ae61b7c431ff3 /src/server/index.ts
parent8d9c9d0f51be91ee10b631be9f464af0822bb9be (diff)
final batcher fixes
Diffstat (limited to 'src/server/index.ts')
-rw-r--r--src/server/index.ts11
1 files changed, 5 insertions, 6 deletions
diff --git a/src/server/index.ts b/src/server/index.ts
index 12ceb9886..4c4cb84d6 100644
--- a/src/server/index.ts
+++ b/src/server/index.ts
@@ -841,10 +841,8 @@ app.post(RouteStore.googlePhotosMediaUpload, async (req, res) => {
let failed = 0;
- const newMediaItems = await BatchedArray.from(mediaInput).batchedMapInterval({
- batcher: { batchSize: 25 },
- interval: { magnitude: 100, unit: TimeUnit.Milliseconds },
- converter: async (batch: GooglePhotosUploadUtils.MediaInput[]) => {
+ const newMediaItems = await BatchedArray.from(mediaInput, { batchSize: 25 }).batchedMapInterval(
+ async (batch: GooglePhotosUploadUtils.MediaInput[]) => {
const newMediaItems: NewMediaItem[] = [];
for (let element of batch) {
const uploadToken = await GooglePhotosUploadUtils.DispatchGooglePhotosUpload(element.url);
@@ -858,8 +856,9 @@ app.post(RouteStore.googlePhotosMediaUpload, async (req, res) => {
}
}
return newMediaItems;
- }
- });
+ },
+ { magnitude: 100, unit: TimeUnit.Milliseconds }
+ );
if (failed) {
return _error(res, tokenError);