XCTRxHandle 테스트 케이스

테스트케이스

let scheduler = ConcurrentDispatchQueueScheduler.init(qos: DispatchQoS.userInteractive)
let a = Observable<Int>.just(3).delay(3, scheduler: scheduler).debug("A")
let b = Observable<Int>.just(2).delay(2, scheduler: scheduler).debug("B")
// observable의 stream은 3을 전달. error 없음, XCTWaiter.Result는 completed
XCTRxHandle(testcase: self, timeout: 5, observable: a, value: {
	XCTAssertEqual($0, 3)
}, error: {
	XCTAssertNil($0)
}, result: {
	XCTAssertEqual($0, .completed)
})
// observable의 stream은 3을 전달. error 없음, XCTWaiter.Result는 timedOut
XCTRxHandle(testcase: self, timeout: 1, observable: a, value: {
	XCTAssertEqual($0, 3)
}, error: {
	XCTAssertNil($0)
}, result: {
	XCTAssertEqual($0, .timedOut)
})
// observable의 stream은 2를 전달. error 없음, XCTWaiter.Result는 completed
XCTRxHandle(testcase: self, timeout: 5, observable: b, value: {
	XCTAssertEqual($0, 2)
}, error: {
	XCTAssertNil($0)
}, result: {
	XCTAssertEqual($0, .completed)
})