Skip to content

Commit

Permalink
Fix before/after in DeferredJVMSuite
Browse files Browse the repository at this point in the history
  • Loading branch information
iRevive committed Jan 10, 2025
1 parent ce3f8dd commit e72d87c
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ abstract class BaseDeferredJVMTests(parallelism: Int) extends FunSuite {

implicit val runtime: IORuntime = IORuntime.global

def before: Any =
override def beforeEach(context: BeforeEach): Unit =
service = Executors.newFixedThreadPool(
parallelism,
new ThreadFactory {
Expand All @@ -58,7 +58,7 @@ abstract class BaseDeferredJVMTests(parallelism: Int) extends FunSuite {
}
)

def after: Any = {
override def afterEach(context: AfterEach): Unit = {
service.shutdown()
assert(service.awaitTermination(60, TimeUnit.SECONDS), "has active threads")
}
Expand Down

0 comments on commit e72d87c

Please sign in to comment.