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
61
61
$ input = clone $ this ->input ;
62
62
$ page = $ this ;
63
63
while (true ) {
64
- if ($ page ->getUnprocessedKeys ()) {
65
- $ input ->setRequestItems ($ page ->getUnprocessedKeys ());
64
+ $ page ->initialize ();
65
+ if ($ page ->unprocessedKeys ) {
66
+ $ input ->setRequestItems ($ page ->unprocessedKeys );
66
67
67
68
$ this ->registerPrefetch ($ nextPage = $ client ->batchGetItem ($ input ));
68
69
} else {
69
70
$ nextPage = null ;
70
71
}
71
72
72
- yield from $ page ->getConsumedCapacity ( true ) ;
73
+ yield from $ page ->consumedCapacity ;
73
74
74
75
if (null === $ nextPage ) {
75
76
break ;
Original file line number Diff line number Diff line change @@ -68,15 +68,16 @@ public function getTableNames(bool $currentPageOnly = false): iterable
68
68
$ input = clone $ this ->input ;
69
69
$ page = $ this ;
70
70
while (true ) {
71
- if ($ page ->getLastEvaluatedTableName ()) {
72
- $ input ->setExclusiveStartTableName ($ page ->getLastEvaluatedTableName ());
71
+ $ page ->initialize ();
72
+ if ($ page ->lastEvaluatedTableName ) {
73
+ $ input ->setExclusiveStartTableName ($ page ->lastEvaluatedTableName );
73
74
74
75
$ this ->registerPrefetch ($ nextPage = $ client ->listTables ($ input ));
75
76
} else {
76
77
$ nextPage = null ;
77
78
}
78
79
79
- yield from $ page ->getTableNames ( true ) ;
80
+ yield from $ page ->tableNames ;
80
81
81
82
if (null === $ nextPage ) {
82
83
break ;
Original file line number Diff line number Diff line change @@ -92,15 +92,16 @@ public function getItems(bool $currentPageOnly = false): iterable
92
92
$ input = clone $ this ->input ;
93
93
$ page = $ this ;
94
94
while (true ) {
95
- if ($ page ->getLastEvaluatedKey ()) {
96
- $ input ->setExclusiveStartKey ($ page ->getLastEvaluatedKey ());
95
+ $ page ->initialize ();
96
+ if ($ page ->lastEvaluatedKey ) {
97
+ $ input ->setExclusiveStartKey ($ page ->lastEvaluatedKey );
97
98
98
99
$ this ->registerPrefetch ($ nextPage = $ client ->query ($ input ));
99
100
} else {
100
101
$ nextPage = null ;
101
102
}
102
103
103
- yield from $ page ->getItems ( true ) ;
104
+ yield from $ page ->items ;
104
105
105
106
if (null === $ nextPage ) {
106
107
break ;
Original file line number Diff line number Diff line change @@ -92,15 +92,16 @@ public function getItems(bool $currentPageOnly = false): iterable
92
92
$ input = clone $ this ->input ;
93
93
$ page = $ this ;
94
94
while (true ) {
95
- if ($ page ->getLastEvaluatedKey ()) {
96
- $ input ->setExclusiveStartKey ($ page ->getLastEvaluatedKey ());
95
+ $ page ->initialize ();
96
+ if ($ page ->lastEvaluatedKey ) {
97
+ $ input ->setExclusiveStartKey ($ page ->lastEvaluatedKey );
97
98
98
99
$ this ->registerPrefetch ($ nextPage = $ client ->scan ($ input ));
99
100
} else {
100
101
$ nextPage = null ;
101
102
}
102
103
103
- yield from $ page ->getItems ( true ) ;
104
+ yield from $ page ->items ;
104
105
105
106
if (null === $ nextPage ) {
106
107
break ;
You can’t perform that action at this time.
0 commit comments