remove unnecessary double-check in getOrCreate (Effect.sync is atomic)
This commit is contained in:
@@ -69,9 +69,6 @@ export namespace Bus {
|
||||
let ps = state.typed.get(type)
|
||||
if (!ps) {
|
||||
ps = yield* PubSub.unbounded<Payload>()
|
||||
// Re-check after yield in case another fiber created one concurrently
|
||||
const existing = state.typed.get(type)
|
||||
if (existing) return existing
|
||||
state.typed.set(type, ps)
|
||||
}
|
||||
return ps
|
||||
|
||||
Reference in New Issue
Block a user