Medium blogpost snippet

Autocomplete.swift

func autocomplete(text: Observable<String>) -> (result: Driver<AutocompleteResult>, isBusy: Driver<Bool>) {
    let provider = self.provider
    let isLoadingSubject = PublishSubject<Bool>()

    let result: Driver<AutocompleteResult> = text
        .do(onNext: { _ in isLoadingSubject.onNext(true) })
        .flatMapLatest { query -> Observable<AutocompleteResult> in
            provider
                .autocomplete(text: query)
                .map { .predictions($0) }
                .catchError { .just(.error($0)) }
        }
        .asDriver(onErrorJustReturn: .predictions([]))
        .do(onNext: { _ in isLoadingSubject.onNext(false) })


    let isLoading = isLoadingSubject
        .asDriver(onErrorJustReturn: false)

    return (result: result, isBusy: isLoading)
}