RxSwift RxTest와 RxBlocking 알아보기

RxSwift RxTest 알아보기

RxTest

• Observable에 가상의 시간 개념을 주입
• 임이의 Observer를 통해 subscribe 여부 관계 없이 검증 가능

//가상의 시간 흐름 생성
let scheduler = TestScheduler(initialColck: 0)

• TestScheduler를 사용해 가상의 시간 흐름을 생성합니다.

// 원하는 시점에 Event가 발생하는 Observable create (구독의 여부와 관계없이 이벤트 발생)
let observable = scheduler.createHotObservable([
	.next(1, "가),
    .next(1, "가)
    .next(1, "가)
    ])
// 원하는 시점에 Event가 발생하는 Observable 생성 (구독이 시작되어야 정해진 순서대로 이벤트 발생)
let observable = scheduler.createColdObservable([
	.next(1, "가),
    .next(1, "가)
    .next(1, "가)
    ])

• Hot과 Cold의 차이는 subscribe의 유무다.

// String을 관찰하는 Observer 생성
let observer = scheduler.createObserver(String.self)

observable
	.subscribe(observer)
    .disposed(by: disposeBag)
    
// 가상의 시간이 모두 흐르도록
scheduler.start()

RxBlocking

• Observable Event 방출을 검증
• 특정 시간동안 방출된 Observable의 Event 검증

// Observable -> BlockingObservable
let observable = Observable.of("A", "B", "C").toBlcoking()

// Observable의 .next 이벤트를 Array로 전환
let values = try! observable.toArray()

// Nimble의 문법을 활용한 Test Assertion
expect(values).to(equal(["A", "B", "C"]))

• toBlocking이라는 것으로 BlockingObservable로 전환을 해준다. 
• toArray라는 것도 있다. 
• 컴플리션이 보장되지 않으면 timeout을 사용하면 된다.