diff --git a/rx.lua b/rx.lua index bef15ac..8df9147 100644 --- a/rx.lua +++ b/rx.lua @@ -283,9 +283,13 @@ end -- @arg {function=tostring} formatter - A function that formats one or more values to be printed. function Observable:dump(name, formatter) name = name and (name .. ' ') or '' - formatter = formatter or tostring - local onNext = function(...) print(name .. 'onNext: ' .. formatter(...)) end + local onNext + if formatter then + onNext = function(...) print(name .. 'onNext: ' .. formatter(...)) end + else + onNext = function(...) print(name .. 'onNext: ', ...) end + end local onError = function(e) print(name .. 'onError: ' .. e) end local onCompleted = function() print(name .. 'onCompleted') end diff --git a/src/observable.lua b/src/observable.lua index ec792c5..9b55707 100644 --- a/src/observable.lua +++ b/src/observable.lua @@ -188,9 +188,13 @@ end -- @arg {function=tostring} formatter - A function that formats one or more values to be printed. function Observable:dump(name, formatter) name = name and (name .. ' ') or '' - formatter = formatter or tostring - local onNext = function(...) print(name .. 'onNext: ' .. formatter(...)) end + local onNext + if formatter then + onNext = function(...) print(name .. 'onNext: ' .. formatter(...)) end + else + onNext = function(...) print(name .. 'onNext: ', ...) end + end local onError = function(e) print(name .. 'onError: ' .. e) end local onCompleted = function() print(name .. 'onCompleted') end