File tree Expand file tree Collapse file tree
sdk/src/main/java/software/amazon/lambda/durable/operation Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -73,10 +73,10 @@ public MapOperation(
7373 }
7474
7575 private void addAllItems () {
76- addAllItemsWithStatus (Collections .nCopies (items .size (), null ));
76+ addUnskippedItems (Collections .nCopies (items .size (), null ));
7777 }
7878
79- private void addAllItemsWithStatus (List <MapResult .MapResultItem .Status > resultItems ) {
79+ private void addUnskippedItems (List <MapResult .MapResultItem .Status > resultItems ) {
8080 // Enqueue all items first.
8181 // If the map is completed when replaying, mapResult != null and the items that have been skipped
8282 // will be skipped during replay.
@@ -143,7 +143,7 @@ protected void replay(Operation existing) {
143143 : null ;
144144 var deserializedResult = result != null ? deserializeResult (result ) : null ;
145145 if (deserializedResult != null ) {
146- addAllItemsWithStatus (deserializedResult .items ().stream ()
146+ addUnskippedItems (deserializedResult .items ().stream ()
147147 .map (MapResult .MapResultItem ::status )
148148 .toList ());
149149 } else {
You can’t perform that action at this time.
0 commit comments