Я использую RxSwift для реактивного программирования и хочу проверить мою модель просмотра.
У меня есть такой отклик:
В представлении модель:
let personNameMessage = input.personName.debounce(0.5).map { name -> String in
return "Person Name = \(name)"
}
return Driver.just(personNameMessage)
и затем в контрольном примере:
let scheduler = TestScheduler(initialClock: 0)
let personNameInput = scheduler.createHotObservable([next(100, "John Doe")])
let personObserver = scheduler.createObserver(String.self)
output.personNameWelcome
.asObservable()
.subscribe(personObserver)
.disposed(disposeBag)
scheduler.start()
print(observer.events)
Но оно не излучало событие. Я пытаюсь добавить scheduler.advanceBy(550)
после scheduler.start()
, но результаты такие же.
Пожалуйста, помогите.
Спасибо.