Function waitForEntityManager

packages/effect/src/unstable/cluster/Sharding.ts:1644–1651

(entityType: string)

  )

  const waitForEntityManager = (entityType: string) => {
    let latch = entityManagerLatches.get(entityType)
    if (!latch) {
      latch = Latch.makeUnsafe()
      entityManagerLatches.set(entityType, latch)
    }
    return latch.await
  }

  // --- Runner health checks ---