RxXCTestCase.swift

//
//  RxXCTestCase.swift
//
//  Created by Muhammad Hassan on 02/12/2020.
//  Copyright © 2020 Muhammad Hassan. All rights reserved.
//

import XCTest
import RxSwift
import RxTest

class RxXCTestCase: XCTestCase {
    
    // MARK: - Reused Properties
    var disposeBag: DisposeBag!
    var schedular: TestScheduler!
    
    override func setUp() {
        disposeBag = DisposeBag()
        schedular = TestScheduler(initialClock: 0)
    }
    
    override func tearDown() {
        disposeBag = nil
        schedular = nil
    }
    
    func performRxTest<T: Equatable>(expectedValue: [Recorded<Event<T>>],
                                     observable: Observable<T>,
                                     line: UInt = #line,
                                     file: StaticString = #file) {
        let observer = schedular.createObserver(T.self)
        observable.bind(to: observer).disposed(by: disposeBag)
        XCTAssertEqual(expectedValue, observer.events, file: file, line: line)
    }
}