@@ -262,13 +262,13 @@ class FetchTests extends FetchSpec {
262
262
" The product of concurrent fetches of the same type implies everything fetched in a single batch" in {
263
263
def aFetch [F [_]: Concurrent ] =
264
264
for {
265
- a <- one(1 ) // round 1
265
+ a <- one(1 ) // round 1
266
266
b <- many(1 ) // round 2
267
267
c <- one(1 )
268
268
} yield c
269
269
def anotherFetch [F [_]: Concurrent ] =
270
270
for {
271
- a <- one(2 ) // round 1
271
+ a <- one(2 ) // round 1
272
272
m <- many(2 ) // round 2
273
273
c <- one(2 )
274
274
} yield c
@@ -292,13 +292,13 @@ class FetchTests extends FetchSpec {
292
292
" Every level of joined concurrent fetches is combined and batched" in {
293
293
def aFetch [F [_]: Concurrent ] =
294
294
for {
295
- a <- one(1 ) // round 1
295
+ a <- one(1 ) // round 1
296
296
b <- many(1 ) // round 2
297
297
c <- one(1 )
298
298
} yield c
299
299
def anotherFetch [F [_]: Concurrent ] =
300
300
for {
301
- a <- one(2 ) // round 1
301
+ a <- one(2 ) // round 1
302
302
m <- many(2 ) // round 2
303
303
c <- one(2 )
304
304
} yield c
@@ -318,15 +318,15 @@ class FetchTests extends FetchSpec {
318
318
" Every level of sequenced concurrent fetches is batched" in {
319
319
def aFetch [F [_]: Concurrent ] =
320
320
for {
321
- a <- List (2 , 3 , 4 ).traverse(one[F ]) // round 1
322
- b <- List (0 , 1 ).traverse(many[F ]) // round 2
321
+ a <- List (2 , 3 , 4 ).traverse(one[F ]) // round 1
322
+ b <- List (0 , 1 ).traverse(many[F ]) // round 2
323
323
c <- List (9 , 10 , 11 ).traverse(one[F ]) // round 3
324
324
} yield c
325
325
326
326
def anotherFetch [F [_]: Concurrent ] =
327
327
for {
328
- a <- List (5 , 6 , 7 ).traverse(one[F ]) // round 1
329
- b <- List (2 , 3 ).traverse(many[F ]) // round 2
328
+ a <- List (5 , 6 , 7 ).traverse(one[F ]) // round 1
329
+ b <- List (2 , 3 ).traverse(many[F ]) // round 2
330
330
c <- List (12 , 13 , 14 ).traverse(one[F ]) // round 3
331
331
} yield c
332
332
0 commit comments