给定一个定时器列表，如果其中一个完成了，如何输出，同时也能够重置列表？

Question

我有一个输出信号，当一个给定的计时器集中的一个超时、完成或整个列表被重置时，它应该输出。

enum DeviceActionStatus {
    case pending
    case completed
    case failed
}

struct DeviceAction {

    let start: Date
    let status: DeviceActionStatus 
    func isTimedOut() -> Bool // if start is over 30 seconds ago
    let id: String

}

输出信号：

let pendingActionUpdated: Signal<[DeviceAction], NoError>

投入：

let completeAction: Signal<String, NoError>
let tick: Signal<Void, NoError>  // runs every 1 second and should iterate to see if any DeviceAction is timed out
let addAction: Signal<DeviceAction, NoError> 
let resetAllActions: Signal<Void, NoError>

它应该输出所有正在运行的设备操作的数组。

let output = Signal.combineLatest( 
                     addAction,
                     resetAllActions,
                     tick,
                     Signal.merge(
                          completeAction,
                          tick.take(first: 1).map { _ in "InvalidActionId" }
                     )) // make sure the combinelatest can fire initially 

我尝试过将它发送到.scan，以便每次addAction被触发时累积起来，并在每次resetAllActions被触发时重置，但是由于无法知道哪些被触发，所以我无法让逻辑工作起来。我如何既能累积一个不断增长的列表，同时又能够在我想要的时候重新设置它？

Answer 1

这看起来像是合并/枚举模式的作业。我自己更像一个RxSwift的家伙，但是如果你把每个信号映射到一个enum中，并将它们合并，那么你就可以将它们正确地接收到扫描中.

enum ActionEvent {
    case complete(String)
    case tick
    case add(DeviceAction)
    case reset
}

merge(
    completeAction.map { ActionEvent.complete($0) },
    tick.map { ActionEvent.tick },
    addAction.map { ActionEvent.add($0) },
    resetAllActions.map { ActionEvent.reset }
).scan([DeviceAction]()) { actions, event in 
    switch event {
    case let .complete(id):
        return actions.filter { $0.id != id }
    case .tick:
        return actions.filter { $0.isTimedOut() == false }
    case let .add(action):
        return actions + [action]
    case .reset:
        let resetDate = Date()
        return actions.map { $0.start = resetDate }
        // or
        return []
        // depending on what "reset" means.
}

Answer 2

在这里很难看到完整的用例，所以我将描述如何区分被触发的addAction和resultAllActions，而只剩下剩下的设计。

您可以在Signal.combineLatest之前将这两个信号合并成一个信号。为了做到这一点，需要将它们映射到相同的类型。对于这一点来说，枚举是完美的：

enum Action {
    case add(DeviceAction)
    case resetAll
}

现在，您可以映射每个信号并将它们合并为单个信号：

let action = Signal.merge(
    addAction.map { Action.add($0) },
    resetAllActions.map { _ in Action.resetAll })

现在，您可以打开scan中的值，并确定它是正在添加的新操作还是重置操作。