ncreated

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

    let result: Driver<AutocompleteResult> = text
        .flatMapLatest { query in
            provider
                .autocomplete(text: query)
                .map { AutocompleteResult.predictions($0) }
                .catchError { .just(AutocompleteResult.error($0)) }

ncreated

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) }

ncreated

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

    let resultAndLoading: Driver<(result: AutocompleteResult?, loading: Bool)> = text
        .flatMapLatest { query -> Observable<(result: AutocompleteResult?, loading: Bool)> in
            provider
                .autocomplete(text: query)
                .map { (result: .predictions($0), loading: false) }
                .catchError { .just((result: .error($0), loading: false)) }

ncreated

let autocomplete = Autocomplete(provider: CountryAutocompleteProvider())
let (results, isLoading) = autocomplete.autocomplete(text: inputText)

ncreated

class SearchViewController: UITableViewController {
    
    @IBOutlet weak var searchBar: UISearchBar!
    @IBOutlet var noResultsView: UIView!
    @IBOutlet var errorView: UIView!
    @IBOutlet weak var errorMessageLabel: UILabel!

    private let disposeBag = DisposeBag()
    private let autocomplete = Autocomplete(provider: CountryAutocompleteProvider())

ncreated

func testItEmitsPredictionsResult() {
    let disposeBag = DisposeBag()
    let provider = MockAutocompleteProvider()
    let autocomplete = Autocomplete(provider: provider)
    let input = SimulatedInput()
    let mockPrediction = Prediction(predictedText: "Italy",
                                    matchingRange: ("It".startIndex..<"It".endIndex))
    let expectation = self.expectation(description: "will emit result")

    let (result, _) = autocomplete.autocomplete(text: input.text)

ncreated

//
//  Toggle.swift
//  Switch
//
//  Created by Maciek Grzybowski on 28.07.2017.
//  Copyright © 2017 ncreated. All rights reserved.
//

import RxSwift
import RxCocoa

ncreated

import RxSwift
import RxCocoa

final class Toggle {

    func manage(change: Observable<Bool>) -> (value: Driver<ToggleValue>,
                                              isBusy: Driver<Bool>) {
        return (value: .empty(), isBusy: .empty()) // TODO
    }
}

ncreated

import RxSwift

protocol ToggleStorage {

    func read() -> Observable<Bool>
    func save(value: Bool) -> Observable<Void>
}

ncreated

import RxSwift

final class NetworkToggleStorage: ToggleStorage {

    // MARK: - Properties

    private var value: Bool

    // MARK: - Initializers