fix: make asynchronous fixtures work concurrently

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)
+})