|
10 年 前 | |
---|---|---|
examples | 10 年 前 | |
rx | 10 年 前 | |
LICENSE | 10 年 前 | |
README.md | 10 年 前 |
How to use:
local Rx = require 'rx'
local observable = Rx.Observable.create(function(observer)
observer.onNext(42)
end)
observable:subscribe(
function(x)
print('onNext: ' .. x)
end,
function(e)
print('onError: ' .. e)
end,
function()
print('Complete')
end
)
See examples for more details.
first
last
map
reduce
sum
combineLatest
MIT, see LICENSE
for details.