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

Lock whole on method

This commit is contained in:
yury 2015-10-21 10:57:44 +03:00
parent f4f94faf47
commit b95ebfb364
1 changed files with 10 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
RxSwift/Observables/Implementations/WithLatestFrom.swift
View File

@ -48,28 +48,22 @@ class WithLatestFromFirst<FirstO: ObservableType, SecondO: ObservableType, Resul
}
func on(event: Event<E>) {
switch event {
case let .Next(value):
guard let latest = _parent._latest else { return }
do {
let res = try _parent._parent._resultSelector(value, latest)
_parent._lock.performLocked {
_parent._lock.performLocked {
switch event {
case let .Next(value):
guard let latest = _parent._latest else { return }
do {
let res = try _parent._parent._resultSelector(value, latest)
_parent.observer?.onNext(res)
}
} catch let e {
_parent._lock.performLocked {
} catch let e {
_parent.observer?.onError(e)
_parent.dispose()
}
}
case .Completed:
_parent._lock.performLocked {
case .Completed:
_parent.observer?.onComplete()
_parent.dispose()
}
case let .Error(error):
_parent._lock.performLocked {
case let .Error(error):
_parent.observer?.onError(error)
_parent.dispose()
}