Epics

Epics.swift

import RxSwift
import Alamofire
import RxAlamofire

func LoadPoliticiansEpic(actions: Observable<Action>) -> Observable<Action> {
    let sessionConfiguration = AppEnvironment.sessionConfiguration
    let sessionManager = SessionManager(configuration: sessionConfiguration)

    return actions
        .filter({ action in
            if case PoliticiansAction.startLoading = action {
                return true
            } else {
                return false
            }
        })
        .map(PoliticiansRequestFactory.request)
        .flatMapLatest({ request in
            return sessionManager.request(request).rx.value()
        })
        .map(PoliticiansAction.load)
        .catchError({ error in
            return Observable.just(PoliticiansAction.fail(error))
        })
}

final class PoliticiansRequestFactory {
    static func request(action: Action) -> Request<[Politicians]> {
        return Request(
            url: URL(string: "/politicians")!,
            method: .get,
            parameters: [:],
            headers: [:],
            parameterEncoding: URLEncoding()
        )
    }
}