Cross-platform suite-local fixtures

ce2/shared/src/main/scala/munit/CatsEffectSuite.scala

@@ -47,4 +47,11 @@ abstract class CatsEffectSuite
       { case e: SyncIO[_] => Future(e.unsafeRunSync())(munitExecutionContext) }
     )
 
+  private[munit] def unsafeRunAndForget[A](ioa: IO[A]): Unit = ioa.unsafeRunAsyncAndForget()
+
+}
+
+object CatsEffectSuite {
+  type Deferred[F[_], A] = cats.effect.concurrent.Deferred[F, A]
+  val Deferred = cats.effect.concurrent.Deferred
 }

ce3/shared/src/main/scala/munit/CatsEffectSuite.scala

@@ -44,4 +44,11 @@ abstract class CatsEffectSuite
       { case e: SyncIO[_] => Future(e.unsafeRunSync())(munitExecutionContext) }
     )
 
+  private[munit] def unsafeRunAndForget[A](ioa: IO[A]): Unit = ioa.unsafeRunAndForget()
+
+}
+
+object CatsEffectSuite {
+  type Deferred[F[_], A] = cats.effect.kernel.Deferred[F, A]
+  val Deferred = cats.effect.kernel.Deferred
 }

common/js/src/main/scala/munit/CatsEffectFixtures.scala → common/js/src/main/scala/munit/CatsEffectFixturesPlatform.scala

@@ -16,4 +16,4 @@
 
 package munit
 
-trait CatsEffectFixtures { self: CatsEffectSuite => }
+trait CatsEffectFixturesPlatform { self: CatsEffectSuite => }

common/jvm/src/main/scala/munit/CatsEffectFixtures.scala → common/jvm/src/main/scala/munit/CatsEffectFixturesPlatform.scala

@@ -18,7 +18,7 @@ package munit
 
 import cats.effect.{IO, Resource}
 
-trait CatsEffectFixtures { self: CatsEffectSuite =>
+trait CatsEffectFixturesPlatform { self: CatsEffectSuite =>
 
   object ResourceSuiteLocalFixture {
 

common/jvm/src/test/scala/munit/CatsEffectFixturesSpec.scala → common/jvm/src/test/scala/munit/CatsEffectFixturesPlatformSpec.scala

@@ -18,7 +18,7 @@ package munit
 
 import cats.effect.{IO, Resource}
 
-class CatsEffectFixturesSpec extends CatsEffectSuite with CatsEffectAssertions {
+class CatsEffectFixturesPlatformSpec extends CatsEffectSuite with CatsEffectAssertions {
 
   var acquired: Int = 0
   var released: Int = 0

common/shared/src/main/scala/munit/CatsEffectFixtures.scala

@@ -0,0 +1,44 @@
+/*
+ * Copyright 2021 Typelevel
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package munit
+
+import cats.effect.{IO, Resource}
+
+trait CatsEffectFixtures extends CatsEffectFixturesPlatform { self: CatsEffectSuite =>
+
+  import CatsEffectSuite.Deferred
+
+  object ResourceSuiteLocalDeferredFixture {
+
+    def apply[T](name: String, resource: Resource[IO, T]): Fixture[IO[T]] =
+      new Fixture[IO[T]](name) {
+        val value: Deferred[IO, (T, IO[Unit])] = Deferred.unsafe
+
+        def apply(): IO[T] = value.get.map(_._1)
+
+        override def beforeAll(): Unit = {
+          val resourceEffect = resource.allocated.flatMap(value.complete)
+          unsafeRunAndForget(resourceEffect)
+        }
+
+        override def afterAll(): Unit = {
+          unsafeRunAndForget(value.get.flatMap(_._2))
+        }
+      }
+  }
+
+}

common/shared/src/test/scala/munit/CatsEffectFixturesSpec.scala

@@ -0,0 +1,61 @@
+/*
+ * Copyright 2021 Typelevel
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package munit
+
+import cats.effect.{IO, Resource}
+
+class CatsEffectFixturesSpec extends CatsEffectSuite with CatsEffectAssertions {
+
+  @volatile var acquired: Int = 0
+  @volatile var released: Int = 0
+
+  val fixture = ResourceSuiteLocalDeferredFixture(
+    "fixture",
+    Resource.make(
+      IO {
+        acquired += 1
+        ()
+      }
+    )(_ =>
+      IO {
+        released += 1
+        ()
+      }
+    )
+  )
+
+  override def munitFixtures = List(fixture)
+
+  override def beforeAll(): Unit = {
+    assertEquals(acquired, 0)
+    assertEquals(released, 0)
+  }
+
+  override def afterAll(): Unit = {
+    assertEquals(acquired, 1)
+    // assertEquals(released, 1) // Release is async, no way to check?
+  }
+
+  test("first test") {
+    fixture().assertEquals(())
+  }
+
+  test("second test") {
+    fixture().assertEquals(())
+  }
+
+}