|
vor 10 Jahren | |
---|---|---|
examples | vor 10 Jahren | |
LICENSE | vor 10 Jahren | |
README.md | vor 10 Jahren | |
rx.lua | vor 10 Jahren |
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.