Merge pull request #58 from shiftcode/batch-write-single-table-fix

fix(batch-write-single-table.request): unprocessedItems check

Author: michaelwittwer

src/dynamo/request/batchwritesingletable/batch-write-single-table.request.ts

@@ -64,13 +64,15 @@ export class BatchWriteSingleTableRequest<T> {
 
     return this.dynamoRx.batchWriteItem(batchWriteItemInput).pipe(
       tap((batchWriteManyResponse: BatchWriteItemOutput) => {
-        if (batchWriteManyResponse.UnprocessedItems) {
+        if (batchWriteManyResponse.UnprocessedItems && batchWriteManyResponse.UnprocessedItems[this.tableName]) {
           this.itemsToProcess.unshift(...batchWriteManyResponse.UnprocessedItems[this.tableName])
         }
       }),
       map((batchWriteManyResponse: BatchWriteItemOutput) => ({
         remainingItems: this.itemsToProcess.length,
-        capacityExceeded: !!batchWriteManyResponse.UnprocessedItems,
+        capacityExceeded: !!(
+          batchWriteManyResponse.UnprocessedItems && batchWriteManyResponse.UnprocessedItems[this.tableName]
+        ),
         consumedCapacity: batchWriteManyResponse.ConsumedCapacity,
       }))
     )