独立开发者

import SwiftBus
import Combine

struct RebelsActivityDetectedEvent: EventRepresentable {
    let planet: String
    let distanceInParsecs: Int
}

let eventBus: EventTransmittable = EventBus()
var subscriptions: Set<AnyCancellable> = []

eventBus.onReceive(RebelsActivityDetectedEvent.self) { event in
    print("Detected rebels \(event.distanceInParsecs) parsecs from us on \(event.planet)")
}
.store(in: &subscriptions)

let event = RebelsActivityDetectedEvent(planet: "Hoth", distanceInParsecs: 12)
eventBus.send(event)

eventBus.onReceive("RebelsActivityDetected") { params in
    print("Detected rebels \(params["distanceInParsecs"]) parsecs from us on \(params["planet"])")
}
.store(in: &subscriptions)

eventBus.send("RebelsActivityDetected", params: ["planet": "Hoth", "distanceInParsecs": 12])

eventBus.onReceive(RebelsActivityDetectedEvent.self, performOn: DispatchQueue.main) { _ in
    print("This will be executed on the main thread")
}
.store(in: &subscriptions)

eventBus.onReceive("JumpedToHyperspace", performOn: DispatchQueue.global(qos: .background)) { _ in
    print("This will be executed on the background thread")
}
.store(in: &subscriptions)

dependencies: [
    .package(url: "https://github.com/mtynior/SwiftBus.git", .upToNextMajor(from: "1.0.0")),
]