fix: make asynchronous fixtures work concurrently (#4403)

packages/runner/src/fixture.ts

@@ -44,7 +44,7 @@ export function mergeContextFixtures(fixtures: Record<string, any>, context: { f
   return context
 }
 
-const fixtureValueMap = new Map<FixtureItem, any>()
+const fixtureValueMaps = new Map<TestContext, Map<FixtureItem, any>>()
 let cleanupFnArray = new Array<() => void | Promise<void>>()
 
 export async function callFixtureCleanup() {
@@ -68,6 +68,10 @@ export function withFixtures(fn: Function, testContext?: TestContext) {
     if (!usedProps.length)
       return fn(context)
 
+    if (!fixtureValueMaps.get(context))
+      fixtureValueMaps.set(context, new Map<FixtureItem, any>())
+    const fixtureValueMap: Map<FixtureItem, any> = fixtureValueMaps.get(context)!
+
     const usedFixtures = fixtures.filter(({ prop }) => usedProps.includes(prop))
     const pendingFixtures = resolveDeps(usedFixtures)
     let cursor = 0

test/core/test/fixture-concurrent.test.ts

@@ -0,0 +1,24 @@
+import { expect, test } from 'vitest'
+
+export const myTest = test.extend<{
+  a: string
+  b: string
+}>({
+  a: async ({ task }: any, use) => {
+    await new Promise<void>(resolve => setTimeout(resolve, 200))
+    await use(task.id)
+  },
+  b: async ({ a }, use) => {
+    await use(a)
+  },
+})
+
+myTest.concurrent('fixture - concurrent test 1', ({ a, b, task }) => {
+  expect(a).toBe(task.id)
+  expect(b).toBe(task.id)
+})
+
+myTest.concurrent('fixture - concurrent test 2', ({ a, b, task }) => {
+  expect(a).toBe(task.id)
+  expect(b).toBe(task.id)
+})