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

RxResult -> throws for skip

This commit is contained in:
Krunoslav Zaher 2015-08-11 09:49:52 +02:00
parent 9d07614be3
commit 0ab1e8d828
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
RxSwift/RxSwift/Observables/Implementations/Skip.swift
View File

@ -29,16 +29,16 @@ class SkipCountSink<ElementType, O: ObserverType where O.Element == ElementType>
case .Next(let value):
if remaining <= 0 {
trySendNext(observer, value)
observer?.on(.Next(value))
}
else {
remaining--
}
case .Error:
trySend(observer, event)
observer?.on(event)
self.dispose()
case .Completed:
trySend(observer, event)
observer?.on(event)
self.dispose()
}
}
@ -82,13 +82,13 @@ class SkipTimeSink<ElementType, S: Scheduler, O: ObserverType where O.Element ==
switch event {
case .Next(let value):
if open {
trySendNext(observer, value)
observer?.on(.Next(value))
}
case .Error:
trySend(observer, event)
observer?.on(event)
self.dispose()
case .Completed:
trySend(observer, event)
observer?.on(event)
self.dispose()
}
}