d
This commit is contained in:
@@ -1,15 +0,0 @@
|
||||
import Combine
|
||||
|
||||
public extension Bus {
|
||||
final class Sender<T> {
|
||||
var subscriptions = [AnyCancellable]()
|
||||
|
||||
public init(
|
||||
_ key: String,
|
||||
_ node: AnyPublisher<T, Never>,
|
||||
opt: [Option] = []
|
||||
) {
|
||||
Bus.send(key, node, opt: opt, sub: &subscriptions)
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -13,3 +13,18 @@ public extension Bus {
|
||||
}
|
||||
}
|
||||
}
|
||||
import Combine
|
||||
|
||||
public extension Bus {
|
||||
final class Sender<T> {
|
||||
var subscriptions = [AnyCancellable]()
|
||||
|
||||
public init(
|
||||
_ key: String,
|
||||
_ node: AnyPublisher<T, Never>,
|
||||
opt: [Option] = []
|
||||
) {
|
||||
Bus.send(key, node, opt: opt, sub: &subscriptions)
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user