Единственный эквивалент RXSWIFT в комбинированном / параллелизме ⇐ IOS

[Anonymous]

Я использовал RxSwift для своих приложений, прежде чем комбинировать, Swift Complorlunly и Swiftui. В RXSWIFT мы можем иметь один , который просто испускается один раз с любым значением, которое очень полезно для запуска функции при запуске события. Я использую его довольно часто, чтобы показать оповещение, потому что нам просто нужно запустить его один раз, когда произошла ошибка. Поскольку у нас нет определенного состояния для предупреждения, мы просто хотим уволить показ оповещения и забыть об этом (поскольку смена состояния будет обрабатываться самим предупреждением, когда предупреждение будет закрыто). Каково эквивалент сигнала в комбинированном или асинхронном ожидании / параллелизме? Вы можете дать мне несколько предложений о том, как я могу это сделать? < /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)
}

}

Я действительно могу добавить (и уже выполнить) задачу или отправку, чтобы спать в течение нескольких секунд, а затем сбросить ShowAlert в ноль, но есть ли другой способ? Это кажется грязным делать это так.
Спасибо.

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