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