17
17
18
18
import java .util .ArrayList ;
19
19
import java .util .List ;
20
- import java .util .stream .Collectors ;
21
20
22
21
import kotlin .Pair ;
23
22
@@ -61,9 +60,11 @@ public void clear() throws Exception {
61
60
final Request request = new Request (url , file );
62
61
requestList .add (request );
63
62
}
64
- final List <DownloadInfo > downloadInfoList =
65
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
66
- .collect (Collectors .toList ());
63
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
64
+ for (Request request : requestList ) {
65
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
66
+ downloadInfoList .add (downloadInfo );
67
+ }
67
68
databaseManager .insert (downloadInfoList );
68
69
databaseManager .deleteAll ();
69
70
final List <DownloadInfo > downloads = databaseManager .get ();
@@ -91,13 +92,15 @@ public void multiInsert() throws Exception {
91
92
final Request request = new Request (url , file );
92
93
requestList .add (request );
93
94
}
94
- final List <DownloadInfo > downloadInfoList =
95
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
96
- .collect (Collectors .toList ());
95
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
96
+ for (Request request : requestList ) {
97
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
98
+ downloadInfoList .add (downloadInfo );
99
+ }
97
100
final List <Pair <DownloadInfo , Boolean >> insertedList = databaseManager .insert (downloadInfoList );
98
- final boolean anyFailed = insertedList . stream ()
99
- . anyMatch ( integerBooleanPair -> ! integerBooleanPair .getSecond ());
100
- assertTrue (! anyFailed );
101
+ for ( Pair < DownloadInfo , Boolean > downloadInfoBooleanPair : insertedList ) {
102
+ assertTrue ( downloadInfoBooleanPair .getSecond ());
103
+ }
101
104
}
102
105
103
106
@ Test
@@ -122,14 +125,17 @@ public void deleteMulti() throws Exception {
122
125
final Request request = new Request (url , file );
123
126
requestList .add (request );
124
127
}
125
- final List <DownloadInfo > downloadInfoList =
126
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
127
- .collect (Collectors .toList ());
128
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
129
+ for (Request request : requestList ) {
130
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
131
+ downloadInfoList .add (downloadInfo );
132
+ }
128
133
databaseManager .insert (downloadInfoList );
129
134
databaseManager .delete (downloadInfoList );
130
- final List <Integer > ids = downloadInfoList .stream ()
131
- .mapToInt (Download ::getId )
132
- .boxed ().collect (Collectors .toList ());
135
+ final List <Integer > ids = new ArrayList <>();
136
+ for (DownloadInfo downloadInfo : downloadInfoList ) {
137
+ ids .add (downloadInfo .getId ());
138
+ }
133
139
final List <DownloadInfo > queryList = databaseManager .get (ids );
134
140
assertEquals (0 , queryList .size ());
135
141
}
@@ -165,9 +171,11 @@ public void updateMulti() throws Exception {
165
171
final Request request = new Request (url , file );
166
172
requestList .add (request );
167
173
}
168
- final List <DownloadInfo > downloadInfoList =
169
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
170
- .collect (Collectors .toList ());
174
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
175
+ for (Request request : requestList ) {
176
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
177
+ downloadInfoList .add (downloadInfo );
178
+ }
171
179
databaseManager .insert (downloadInfoList );
172
180
final int groupId = 2 ;
173
181
final Priority priority = Priority .HIGH ;
@@ -179,9 +187,10 @@ public void updateMulti() throws Exception {
179
187
downloadInfo .setStatus (status );
180
188
}
181
189
databaseManager .update (downloadInfoList );
182
- final List <Integer > ids = downloadInfoList .stream ()
183
- .mapToInt (Download ::getId )
184
- .boxed ().collect (Collectors .toList ());
190
+ final List <Integer > ids = new ArrayList <>();
191
+ for (DownloadInfo downloadInfo : downloadInfoList ) {
192
+ ids .add (downloadInfo .getId ());
193
+ }
185
194
final List <DownloadInfo > queryList = databaseManager .get (ids );
186
195
assertNotNull (queryList );
187
196
assertEquals (ids .size (), queryList .size ());
@@ -204,9 +213,11 @@ public void get() throws Exception {
204
213
final Request request = new Request (url , file );
205
214
requestList .add (request );
206
215
}
207
- final List <DownloadInfo > downloadInfoList =
208
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
209
- .collect (Collectors .toList ());
216
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
217
+ for (Request request : requestList ) {
218
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
219
+ downloadInfoList .add (downloadInfo );
220
+ }
210
221
databaseManager .insert (downloadInfoList );
211
222
final List <DownloadInfo > queryList = databaseManager .get ();
212
223
assertNotNull (queryList );
@@ -236,13 +247,16 @@ public void getIds() throws Exception {
236
247
final Request request = new Request (url , file );
237
248
requestList .add (request );
238
249
}
239
- final List <DownloadInfo > downloadInfoList =
240
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
241
- .collect (Collectors .toList ());
250
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
251
+ for (Request request : requestList ) {
252
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
253
+ downloadInfoList .add (downloadInfo );
254
+ }
242
255
databaseManager .insert (downloadInfoList );
243
- final List <Integer > ids = downloadInfoList .stream ()
244
- .mapToInt (Download ::getId )
245
- .boxed ().collect (Collectors .toList ());
256
+ final List <Integer > ids = new ArrayList <>();
257
+ for (DownloadInfo downloadInfo : downloadInfoList ) {
258
+ ids .add (downloadInfo .getId ());
259
+ }
246
260
final List <DownloadInfo > queryList = databaseManager .get (ids );
247
261
assertNotNull (queryList );
248
262
assertEquals (downloadInfoList .size (), queryList .size ());
@@ -264,10 +278,14 @@ public void getStatus() throws Exception {
264
278
final Request request = new Request (url , file );
265
279
requestList .add (request );
266
280
}
267
- final List <DownloadInfo > downloadInfoList =
268
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
269
- .collect (Collectors .toList ());
270
- downloadInfoList .forEach (download -> download .setStatus (status ));
281
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
282
+ for (Request request : requestList ) {
283
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
284
+ downloadInfoList .add (downloadInfo );
285
+ }
286
+ for (DownloadInfo downloadInfo : downloadInfoList ) {
287
+ downloadInfo .setStatus (status );
288
+ }
271
289
databaseManager .insert (downloadInfoList );
272
290
final List <DownloadInfo > queryList = databaseManager .getByStatus (status );
273
291
assertNotNull (queryList );
@@ -291,10 +309,14 @@ public void getGroup() throws Exception {
291
309
final Request request = new Request (url , file );
292
310
requestList .add (request );
293
311
}
294
- final List <DownloadInfo > downloadInfoList =
295
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
296
- .collect (Collectors .toList ());
297
- downloadInfoList .forEach (download -> download .setGroup (group ));
312
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
313
+ for (Request request : requestList ) {
314
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
315
+ downloadInfoList .add (downloadInfo );
316
+ }
317
+ for (DownloadInfo downloadInfo : downloadInfoList ) {
318
+ downloadInfo .setGroup (group );
319
+ }
298
320
databaseManager .insert (downloadInfoList );
299
321
final List <DownloadInfo > queryList = databaseManager .getByGroup (group );
300
322
assertNotNull (queryList );
@@ -340,10 +362,14 @@ public void getGroupWithStatus() throws Exception {
340
362
request .setGroupId (group );
341
363
requestList .add (request );
342
364
}
343
- final List <DownloadInfo > downloadInfoList =
344
- requestList .stream ().map (FetchTypeConverterExtensions ::toDownloadInfo )
345
- .collect (Collectors .toList ());
346
- downloadInfoList .forEach (download -> download .setStatus (status ));
365
+ final List <DownloadInfo > downloadInfoList = new ArrayList <>();
366
+ for (Request request : requestList ) {
367
+ final DownloadInfo downloadInfo = FetchTypeConverterExtensions .toDownloadInfo (request );
368
+ downloadInfoList .add (downloadInfo );
369
+ }
370
+ for (DownloadInfo downloadInfo : downloadInfoList ) {
371
+ downloadInfo .setStatus (status );
372
+ }
347
373
databaseManager .insert (downloadInfoList );
348
374
final List <DownloadInfo > queryList = databaseManager .getDownloadsInGroupWithStatus (group , status );
349
375
assertNotNull (queryList );
0 commit comments