bjornbytes
/
RxLua
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Rename 'continue' -> '_continue'.

master
PotcFdk 2019-03-01 14:25:00 +01:00
parent b2c4522f4a
commit f460f9420f
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rx.lua
View File

@ -450,12 +450,12 @@ function Observable:catch(handler)
return observer:onCompleted()
end
local success, continue = pcall(handler, e)
if success and continue then
local success, _continue = pcall(handler, e)
if success and _continue then
if subscription then subscription:unsubscribe() end
continue:subscribe(observer)
_continue:subscribe(observer)
else
observer:onError(success and e or continue)
observer:onError(success and e or _continue)
end
end

8
src/operators/catch.lua
View File

@ -21,12 +21,12 @@ function Observable:catch(handler)
return observer:onCompleted()
end
local success, continue = pcall(handler, e)
if success and continue then
local success, _continue = pcall(handler, e)
if success and _continue then
if subscription then subscription:unsubscribe() end
continue:subscribe(observer)
_continue:subscribe(observer)
else
observer:onError(success and e or continue)
observer:onError(success and e or _continue)
end
end