Function handler

packages/opencode/test/server/global-bus.ts:12–21

(event: GlobalEvent)

    const cleanup = () => GlobalBus.off("event", handler)

    const handler = (event: GlobalEvent) => {
      try {
        if (!input.predicate(event)) return
        cleanup()
        resume(Effect.succeed(event))
      } catch (error) {
        cleanup()
        resume(Effect.fail(error))
      }
    }

    GlobalBus.on("event", handler)
    return Effect.sync(cleanup)