File tree Expand file tree Collapse file tree 4 files changed +16
-12
lines changed Expand file tree Collapse file tree 4 files changed +16
-12
lines changed Original file line number Diff line number Diff line change @@ -61,15 +61,16 @@ public function getConsumedCapacity(bool $currentPageOnly = false): iterable
6161 $ input = clone $ this ->input ;
6262 $ page = $ this ;
6363 while (true ) {
64- if ($ page ->getUnprocessedKeys ()) {
65- $ input ->setRequestItems ($ page ->getUnprocessedKeys ());
64+ $ page ->initialize ();
65+ if ($ page ->unprocessedKeys ) {
66+ $ input ->setRequestItems ($ page ->unprocessedKeys );
6667
6768 $ this ->registerPrefetch ($ nextPage = $ client ->batchGetItem ($ input ));
6869 } else {
6970 $ nextPage = null ;
7071 }
7172
72- yield from $ page ->getConsumedCapacity ( true ) ;
73+ yield from $ page ->consumedCapacity ;
7374
7475 if (null === $ nextPage ) {
7576 break ;
Original file line number Diff line number Diff line change @@ -68,15 +68,16 @@ public function getTableNames(bool $currentPageOnly = false): iterable
6868 $ input = clone $ this ->input ;
6969 $ page = $ this ;
7070 while (true ) {
71- if ($ page ->getLastEvaluatedTableName ()) {
72- $ input ->setExclusiveStartTableName ($ page ->getLastEvaluatedTableName ());
71+ $ page ->initialize ();
72+ if ($ page ->lastEvaluatedTableName ) {
73+ $ input ->setExclusiveStartTableName ($ page ->lastEvaluatedTableName );
7374
7475 $ this ->registerPrefetch ($ nextPage = $ client ->listTables ($ input ));
7576 } else {
7677 $ nextPage = null ;
7778 }
7879
79- yield from $ page ->getTableNames ( true ) ;
80+ yield from $ page ->tableNames ;
8081
8182 if (null === $ nextPage ) {
8283 break ;
Original file line number Diff line number Diff line change @@ -92,15 +92,16 @@ public function getItems(bool $currentPageOnly = false): iterable
9292 $ input = clone $ this ->input ;
9393 $ page = $ this ;
9494 while (true ) {
95- if ($ page ->getLastEvaluatedKey ()) {
96- $ input ->setExclusiveStartKey ($ page ->getLastEvaluatedKey ());
95+ $ page ->initialize ();
96+ if ($ page ->lastEvaluatedKey ) {
97+ $ input ->setExclusiveStartKey ($ page ->lastEvaluatedKey );
9798
9899 $ this ->registerPrefetch ($ nextPage = $ client ->query ($ input ));
99100 } else {
100101 $ nextPage = null ;
101102 }
102103
103- yield from $ page ->getItems ( true ) ;
104+ yield from $ page ->items ;
104105
105106 if (null === $ nextPage ) {
106107 break ;
Original file line number Diff line number Diff line change @@ -92,15 +92,16 @@ public function getItems(bool $currentPageOnly = false): iterable
9292 $ input = clone $ this ->input ;
9393 $ page = $ this ;
9494 while (true ) {
95- if ($ page ->getLastEvaluatedKey ()) {
96- $ input ->setExclusiveStartKey ($ page ->getLastEvaluatedKey ());
95+ $ page ->initialize ();
96+ if ($ page ->lastEvaluatedKey ) {
97+ $ input ->setExclusiveStartKey ($ page ->lastEvaluatedKey );
9798
9899 $ this ->registerPrefetch ($ nextPage = $ client ->scan ($ input ));
99100 } else {
100101 $ nextPage = null ;
101102 }
102103
103- yield from $ page ->getItems ( true ) ;
104+ yield from $ page ->items ;
104105
105106 if (null === $ nextPage ) {
106107 break ;
You can’t perform that action at this time.
0 commit comments