Skip to content

Commit bdff54c

Browse files
authored
fix: Typo typo causing some operators to not emit on source completion (#537)
1 parent 139153f commit bdff54c

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/rx/src/Shared/Rx.lua

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -645,11 +645,11 @@ function Rx.reduce(reducer, seed)
645645
end,
646646
function(...)
647647
sub:Fail(...)
648-
end),
648+
end,
649649
function()
650650
-- On complete emit the result.
651651
sub:Fire(current)
652-
end)
652+
end))
653653

654654
return maid
655655
end)
@@ -750,13 +750,13 @@ function Rx.endWith(values)
750750
sub:Fire(item)
751751
end
752752
sub:Fail(...)
753-
end),
753+
end,
754754
function()
755755
for _, item in pairs(values) do
756756
sub:Fire(item)
757757
end
758758
sub:Complete()
759-
end)
759+
end))
760760

761761
return maid
762762
end)
@@ -1330,15 +1330,15 @@ function Rx.combineLatestAll()
13301330
end,
13311331
function(...)
13321332
sub:Fail(...)
1333-
end),
1333+
end,
13341334
function()
13351335
if not alive then
13361336
return
13371337
end
13381338

13391339
maid:GiveTask(Rx.combineLatest(observables))
13401340
:Subscribe(sub:GetFireFailComplete())
1341-
end)
1341+
end))
13421342

13431343
return maid
13441344
end)

0 commit comments

Comments
 (0)