Reactive Extensions for Lua

bjorn d64834faa6 Initial commit; 10 年 前
examples d64834faa6 Initial commit; 10 年 前
rx d64834faa6 Initial commit; 10 年 前
LICENSE d64834faa6 Initial commit; 10 年 前
README.md d64834faa6 Initial commit; 10 年 前

README.md

RxLua

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.

Combinators

  • first
  • last
  • map
  • reduce
  • sum
  • combineLatest

License

MIT, see LICENSE for details.