func test_start_stop_lifecycle()

in RIBsTests/Worker/WorkerTests.swift [87:107]


    func test_start_stop_lifecycle() {
        worker.isStartedStream
            .take(1)
            .subscribe(onNext: { XCTAssertFalse($0) })
            .disposed(by: disposable)

        interactor.activate()
        worker.start(interactor)

        worker.isStartedStream
            .take(1)
            .subscribe(onNext: { XCTAssertTrue($0) })
            .disposed(by: disposable)

        worker.stop()

        worker.isStartedStream
            .take(1)
            .subscribe(onNext: { XCTAssertFalse($0) })
            .disposed(by: disposable)
    }