dependencies: [
    .package(url: "https://github.com/ThomasCle/events.git", from: "1.0.0")
]

targets: [
    .target(
        name: "YourTarget",
        dependencies: ["Events"]),
]

let event = Event<String>()

await event.subscribe(for: self) { value in
    print("Received value: \(value)")
}

// ...

await event.fire(with: "Hello world 🕺🏻")

import Events

actor UserManager {
    private(set) var user: User?

    let onLogin = Event<User>()
    let onLogout = Event<Void>()
    
    func login(userName: String, password: String) async throws {
        let user = try await userService.login(username: username, password: password)
        self.user = user
        
        // Fire the event to notify subscribers
        await onLogin.fire(with: user)
    }

    func logout() async {
        user = nil

        // Fire event without value.
        await onLogout.fire()
    }
}

@Observable
final class ViewModel {
    private(set) var user: User?
    private let userManager = UserManager()

    init() {
        Task {
            await setup()
        }
    }
    
    deinit { 
        // ... no need to unsubscribe, the deallocation will throw away the subscription because `self` is the subscriber.
    }
    
    func setup() async {
        await userManager.oLogin.subscribe(for: self) { [weak self] user in
            self?.user = user
        }
    }
}

// Unsubscribe when no longer needed
await userManager.onLogin.unsubscribe(for: self)