Medium blogpost snippet

Toggle.swift

func manage(change: Observable<Bool>) -> (value: Driver<ToggleValue>, isBusy: Driver<Bool>) {
    let storage = self.storage

    let initialValue = storage
        .read()
        .map { ToggleValue.initial($0) }
        .catchError { Observable.just( ToggleValue.unknown($0) ) }

    let valueAfterSaving = change
        .flatMap { valueToSave -> Observable<ToggleValue> in
            storage
                .save(value: valueToSave)
                .map { ToggleValue.updated(valueToSave) }
                .catchErrorJustReturn(ToggleValue.fallback(!valueToSave))
        }

    let value = Observable.merge(initialValue, valueAfterSaving)
        .asDriver(onErrorRecover: { Driver.just(ToggleValue.unknown($0)) })

    return (value: value, isBusy: .empty())
}