diff --git a/.scalafmt.conf b/.scalafmt.conf index a0519b33..04baac28 100644 --- a/.scalafmt.conf +++ b/.scalafmt.conf @@ -1,4 +1,4 @@ -version = 3.0.4 +version = 3.0.5 style = defaultWithAlign maxColumn = 100 diff --git a/fetch/src/test/scala/FetchReportingTests.scala b/fetch/src/test/scala/FetchReportingTests.scala index 5b02c938..ce362af8 100644 --- a/fetch/src/test/scala/FetchReportingTests.scala +++ b/fetch/src/test/scala/FetchReportingTests.scala @@ -87,8 +87,8 @@ class FetchReportingTests extends FetchSpec { "Single fetches combined with traverse are run in one round" in { def fetch[F[_]: Concurrent] = for { - manies <- many(3) // round 1 - ones <- manies.traverse(one[F]) // round 2 + manies <- many(3) // round 1 + ones <- manies.traverse(one[F]) // round 2 } yield ones val io = Fetch.runLog[IO](fetch) @@ -119,9 +119,9 @@ class FetchReportingTests extends FetchSpec { def anotherFetch[F[_]: Concurrent] = for { - a <- one(2) // round 1 (batched) + a <- one(2) // round 1 (batched) m <- many(4) // round 2 - c <- one(3) // round 3 (deduplicated) + c <- one(3) // round 3 (deduplicated) } yield c def fetch[F[_]: Concurrent] = diff --git a/fetch/src/test/scala/FetchTests.scala b/fetch/src/test/scala/FetchTests.scala index 93fb0752..aeebadbd 100644 --- a/fetch/src/test/scala/FetchTests.scala +++ b/fetch/src/test/scala/FetchTests.scala @@ -262,13 +262,13 @@ class FetchTests extends FetchSpec { "The product of concurrent fetches of the same type implies everything fetched in a single batch" in { def aFetch[F[_]: Concurrent] = for { - a <- one(1) // round 1 + a <- one(1) // round 1 b <- many(1) // round 2 c <- one(1) } yield c def anotherFetch[F[_]: Concurrent] = for { - a <- one(2) // round 1 + a <- one(2) // round 1 m <- many(2) // round 2 c <- one(2) } yield c @@ -292,13 +292,13 @@ class FetchTests extends FetchSpec { "Every level of joined concurrent fetches is combined and batched" in { def aFetch[F[_]: Concurrent] = for { - a <- one(1) // round 1 + a <- one(1) // round 1 b <- many(1) // round 2 c <- one(1) } yield c def anotherFetch[F[_]: Concurrent] = for { - a <- one(2) // round 1 + a <- one(2) // round 1 m <- many(2) // round 2 c <- one(2) } yield c @@ -318,15 +318,15 @@ class FetchTests extends FetchSpec { "Every level of sequenced concurrent fetches is batched" in { def aFetch[F[_]: Concurrent] = for { - a <- List(2, 3, 4).traverse(one[F]) // round 1 - b <- List(0, 1).traverse(many[F]) // round 2 + a <- List(2, 3, 4).traverse(one[F]) // round 1 + b <- List(0, 1).traverse(many[F]) // round 2 c <- List(9, 10, 11).traverse(one[F]) // round 3 } yield c def anotherFetch[F[_]: Concurrent] = for { - a <- List(5, 6, 7).traverse(one[F]) // round 1 - b <- List(2, 3).traverse(many[F]) // round 2 + a <- List(5, 6, 7).traverse(one[F]) // round 1 + b <- List(2, 3).traverse(many[F]) // round 2 c <- List(12, 13, 14).traverse(one[F]) // round 3 } yield c