TouchInstinct
/
RxSwift
311
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

`trySend` to `?.on` and cleanup for `timer`

This commit is contained in:
Krunoslav Zaher 2015-08-13 22:23:25 +02:00
parent 7427c227fc
commit 753520b406
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
RxSwift/RxSwift/Observables/Implementations/Timer.swift
View File

@ -20,7 +20,7 @@ class TimerSink<S: Scheduler, O: ObserverType where O.Element == Int64> : Sink<O
func run() -> 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<S: Scheduler, O: ObserverType where O.Element == Int64> :
func run() -> Disposable {
let result = self.parent.scheduler.scheduleRelative((), dueTime: self.parent.dueTime) { (_) -> RxResult<Disposable> in
trySendNext(self.observer, 0)
trySendCompleted(self.observer)
self.observer?.on(.Next(0))
self.observer?.on(.Completed)
return NopDisposableResult
}