Эквивалент сигнала RXSWIFT в комбинированном / параллелизме ⇐ IOS

[Anonymous]

Я использовал RxSwift для своих приложений, прежде чем комбинировать, Swift Complorlunly и Swiftui. В RXSWIFT мы можем иметь сигнал , который просто испускается без повторения предыдущего значения, которое очень полезно для запуска фанка при запуске события. Я использую его довольно часто, чтобы показать предупреждение, потому что нам просто нужно запускать его каждый раз, когда возникала ошибка. Так что я могу просто сделать: < /p>
let showAlertRelay = PublishRelay()
let showAlert: Signal = showAlertRelay.asSignal()

//-- when subscribed before this, will emit 3x, even though the element is still the same Void
showAlert.accept(())
//-- when subscribed before this, will emit 2x, even though the element is still the same Void
showAlert.accept(())
//-- when subscribed before this, will emit 1x
showAlert.accept(())
//-- when subscribed before this, will emit 0x
< /code>
Издатель может излучать тот же элемент, и он все равно повлияет на изменение в пользовательском интерфейсе. Поскольку у нас нет конкретного состояния для оповещения, мы просто хотим уволить показ оповещения и забыть об этом (поскольку смена состояния будет обрабатываться самим оповещением, когда предупреждение будет закрыто). < /P>
Я попробовал это: < /p>
struct MainView: View {
@ObservedObject private var viewModel: MainViewModel

var body: some View {
ZStack {
....
if let alertText = viewModel.showAlert {
SimpleToast(text: alertText, bgColor: .red, textColor: .white)
}
}
}
}

@MainActor
final class MainViewModel: ObservableObject {
@Published var items: [Item]
@Published var showAlert: String?

let getAllItem: () async -> Result

func fetchAll() {
Task {
let result = await getAllItem()
if let .success(items) = result {
self.items = items
} else {
self.showAlert = "Failed to fetch items..."
}
}
}

}
< /code>
он может излучать только один раз, потому что, очевидно, ShowAlert не изменяется после того, как он изменился с первого раза. Таким образом, тост может показать только один раз.final class MainViewModel {
let itemsRelay = BehaviorRelay(value: [])
let items: Driver = itemsRelay.asDriver()
let showAlertRelay = PublishRelay()
let showAlert: Signal = showAlertRelay.asSignal()

let getAllItem: () -> Single
let disposeBag = DisposeBag()

func fetchAll() {
getAllItem()
.subscribe(to: itemsRelay)
.catchError { [weak self] _ in self?.showAlertRelay.accept("Failed to fetch items...") }
.disposed(by: disposeBag)
}

}
< /code>
Каков эквивалент сигнала в комбинированном или асинхронном ожидании /параллелистике? Можете ли вы дать мне несколько предложений о том, как я могу это сделать? Это кажется грязным делать это так.
Спасибо.

Подробнее здесь: https://stackoverflow.com/questions/797 ... oncurrency