@@ -107,7 +107,7 @@ public void batchGetItem_allProcessed_shouldNotHaveNextPage() {
107
107
108
108
@ Test
109
109
public void test_MultipleIteration_On_Responses_Iterable () {
110
- ScanRequest request = ScanRequest . builder (). tableName ( TABLE_NAME ). limit ( 2 ). build ( );
110
+ ScanRequest request = scanRequest ( 2 );
111
111
ScanIterable scanResponses = dynamo .scanPaginator (request );
112
112
113
113
int count = 0 ;
@@ -128,7 +128,7 @@ public void test_MultipleIteration_On_Responses_Iterable() {
128
128
129
129
@ Test
130
130
public void test_MultipleIteration_On_PaginatedMember_Iterable () {
131
- ScanRequest request = ScanRequest . builder (). tableName ( TABLE_NAME ). limit ( 2 ). build ( );
131
+ ScanRequest request = scanRequest ( 2 );
132
132
SdkIterable <Map <String , AttributeValue >> items = dynamo .scanPaginator (request ).items ();
133
133
134
134
int count = 0 ;
@@ -150,7 +150,7 @@ public void test_MultipleIteration_On_PaginatedMember_Iterable() {
150
150
@ Test
151
151
public void test_MultipleIteration_On_Responses_Stream () {
152
152
int results_per_page = 2 ;
153
- ScanRequest request = ScanRequest . builder (). tableName ( TABLE_NAME ). limit ( results_per_page ). build ( );
153
+ ScanRequest request = scanRequest ( results_per_page );
154
154
ScanIterable scanResponses = dynamo .scanPaginator (request );
155
155
156
156
// Iterate once
@@ -169,8 +169,7 @@ public void test_MultipleIteration_On_Responses_Stream() {
169
169
170
170
@ Test
171
171
public void test_MultipleIteration_On_PaginatedMember_Stream () {
172
- int results_per_page = 2 ;
173
- ScanRequest request = ScanRequest .builder ().tableName (TABLE_NAME ).limit (results_per_page ).build ();
172
+ ScanRequest request = scanRequest (2 );
174
173
SdkIterable <Map <String , AttributeValue >> items = dynamo .scanPaginator (request ).items ();
175
174
176
175
// Iterate once
@@ -195,7 +194,7 @@ public void iteration_On_SameStream_ThrowsError() {
195
194
196
195
@ Test
197
196
public void mix_Iterator_And_Stream_Calls () {
198
- ScanRequest request = ScanRequest . builder (). tableName ( TABLE_NAME ). limit ( 2 ). build ( );
197
+ ScanRequest request = scanRequest ( 2 );
199
198
ScanIterable scanResponses = dynamo .scanPaginator (request );
200
199
201
200
assertEquals (ITEM_COUNT , scanResponses .stream ().flatMap (r -> r .items ().stream ())
@@ -226,4 +225,7 @@ private static void putTestData() {
226
225
}
227
226
}
228
227
228
+ private ScanRequest scanRequest (int limit ) {
229
+ return ScanRequest .builder ().tableName (TABLE_NAME ).consistentRead (true ).limit (limit ).build ();
230
+ }
229
231
}
0 commit comments