diff --git a/RxSwift/RxSwift/Observables/Implementations/Timer.swift b/RxSwift/RxSwift/Observables/Implementations/Timer.swift index 5d10a7e5..400f8374 100644 --- a/RxSwift/RxSwift/Observables/Implementations/Timer.swift +++ b/RxSwift/RxSwift/Observables/Implementations/Timer.swift @@ -20,7 +20,7 @@ class TimerSink : Sink Disposable { let result = self.parent.schedulePeriodic(state: 0, startAfter: self.parent.dueTime, period: self.parent.period!) { state in - trySendNext(self.observer, state) + self.observer?.on(.Next(state)) return state &+ 1 } @@ -40,8 +40,8 @@ class TimerOneOffSink : func run() -> Disposable { let result = self.parent.scheduler.scheduleRelative((), dueTime: self.parent.dueTime) { (_) -> RxResult in - trySendNext(self.observer, 0) - trySendCompleted(self.observer) + self.observer?.on(.Next(0)) + self.observer?.on(.Completed) return NopDisposableResult }