diff options
author | Sam Wilkins <samwilkins333@gmail.com> | 2019-09-21 14:27:10 -0400 |
---|---|---|
committer | Sam Wilkins <samwilkins333@gmail.com> | 2019-09-21 14:27:10 -0400 |
commit | f529d7d22162689c08830418da67a89778111e16 (patch) | |
tree | 5ad0ede9cbbfbcae3ea7c850ab0ae61b7c431ff3 /src/server/index.ts | |
parent | 8d9c9d0f51be91ee10b631be9f464af0822bb9be (diff) |
final batcher fixes
Diffstat (limited to 'src/server/index.ts')
-rw-r--r-- | src/server/index.ts | 11 |
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); |