Тестирование поведения объекта / реле в RxSwift - PullRequest
Новая
       26

Тестирование поведения объекта / реле в RxSwift

0 голосов
/ 04 января 2019

У меня проблемы с тестированием BehaviorRelay.Следующий минимальный код связывает наблюдаемое с BehaviorRelay, но при тестировании тесты не заканчиваются и зависают - наблюдаемая продолжает генерировать события, потому что она начинается с Observable.timer.При избавлении от метода bindRx и проверке только наблюдаемого он работает без проблем.Но я хотел бы проверить класс правильно - имеет ли это смысл?

Как мне сделать эту работу? 

import XCTest
import RxSwift
import RxCocoa

struct TestObject: Codable {
    var a: Int?
    var b: Int?

    private enum CodingKeys: String, CodingKey {
        case a = "test"
        case b
    }
}

extension TestObject: Equatable {
    static func == (lhs: TestObject, rhs: TestObject) -> Bool {
        return lhs.a == rhs.a && lhs.b == rhs.b
    }
}

class TestObjectFetcher {
    private let scheduler: SchedulerType
    private let disposeBag = DisposeBag()
    let testObject = BehaviorRelay<TestObject?>(value: nil)
    var syncInterval = 30.0

    init(scheduler: SchedulerType) {
        self.scheduler = scheduler
        self.bindRx()
    }

    var fetchTestObjectObservable: Observable<TestObject?> {
        return Observable<Int>.timer(0, period: self.syncInterval, scheduler: self.scheduler)
            .map { _ -> TestObject? in
                TestObject(a: 1, b: 2)
            }
    }

    private func bindRx() {
        self.fetchTestObjectObservable
            .bind(to: self.testObject)
            .disposed(by: self.disposeBag)
    }
}

class TestObjectFetcherTests: XCTestCase {
    let testScheduler = TestScheduler(initialClock: 0)
    func testTestObjectFetcher() {

        let testObjectFetcher = TestObjectFetcher(scheduler: testScheduler)

        let events: [Recorded<Event<TestObject?>>] = [
            Recorded.next(1, TestObject(a: 1, b: 2)),
            Recorded.next(31, TestObject(a: 1, b: 2)),
            Recorded.next(61, TestObject(a: 1, b: 2))
        ]

        let res = testScheduler.start(created: 0, subscribed: 0, disposed: 90) { () -> Observable<TestObject?> in
            return testObjectFetcher.testObject.asObservable()
        }

        XCTAssertEqual(res.events, events)
    }
}

1 Ответ

0 голосов
/ 06 января 2019

Проблема заключалась в том, что наблюдаемое никогда не завершалось. Добавление scheduler.subscribeAt(100) {} и установка сборщика на ноль решила проблему.

...