func test_workflowReceivesError()

in RIBsTests/Workflow/WorkflowTests.swift [80:103]

• 22 lines of code
• 1 McCabe index (conditional complexity)

    func test_workflowReceivesError() {
        let workflow = TestWorkflow()

        let emptyObservable = Observable.just(((), ()))
        _ = workflow
            .onStep { _ -> Observable<((), ())> in
                return emptyObservable
            }
            .onStep { _, _ -> Observable<((), ())> in
                return emptyObservable
            }
            .onStep { _, _ -> Observable<((), ())> in
                return Observable.error(WorkflowTestError.error)
            }
            .onStep { _, _ -> Observable<((), ())> in
                return emptyObservable
            }
            .commit()
            .subscribe(())

        XCTAssertEqual(0, workflow.completeCallCount)
        XCTAssertEqual(0, workflow.forkCallCount)
        XCTAssertEqual(1, workflow.errorCallCount)
    }