Just put it all in one file;

rx/observable.lua → rx.lua

@@ -1,5 +1,38 @@
-local path = (...):gsub('%.[^%.]+$', '')
-local Observer = require(path .. '.observer')
+local function noop() end
+
+local Observer = {}
+Observer.__index = Observer
+
+function Observer.create(onNext, onError, onCompleted)
+  local self = {
+    _onNext = onNext or noop,
+    _onError = onError or error,
+    _onCompleted = onCompleted or noop,
+    stopped = false
+  }
+
+  return setmetatable(self, Observer)
+end
+
+function Observer:onNext(value)
+  if not self.stopped then
+    self._onNext(value)
+  end
+end
+
+function Observer:onError(e)
+  if not self.stopped then
+    self.stopped = true
+    self._onError(e)
+  end
+end
+
+function Observer:onCompleted()
+  if not self.stopped then
+    self.stopped = true
+    self._onCompleted()
+  end
+end
 
 local Observable = {}
 Observable.__index = Observable
@@ -46,7 +79,6 @@ function Observable:dump(name)
 end
 
 -- Combinators
-
 function Observable:first()
   return Observable.create(function(observer)
     return self:subscribe(function(x)
@@ -62,6 +94,7 @@ function Observable:first()
   end)
 end
 
+
 function Observable:last()
   return Observable.create(function(observer)
     local value
@@ -160,4 +193,7 @@ function Observable:combineLatest(...)
   end)
 end
 
-return Observable
+return {
+  Observer = Observer,
+  Observable = Observable
+}

rx/init.lua

@@ -1,8 +0,0 @@
-local path = (...):gsub('%.init+$', '')
-
-local Rx = {}
-
-Rx.Observable = require(path .. '.observable')
-Rx.Observer = require(path .. '.observer')
-
-return Rx

rx/observer.lua

@@ -1,38 +0,0 @@
-local Observer = {}
-Observer.__index = Observer
-
-local function noop() end
-local function defaultError(e) error(e) end
-
-function Observer.create(onNext, onError, onCompleted)
-  local self = {
-    _onNext = onNext or noop,
-    _onError = onError or defaultError,
-    _onCompleted = onCompleted or noop,
-    stopped = false
-  }
-
-  return setmetatable(self, Observer)
-end
-
-function Observer:onNext(value)
-  if not self.stopped then
-    self._onNext(value)
-  end
-end
-
-function Observer:onError(e)
-  if not self.stopped then
-    self.stopped = true
-    self._onError(e)
-  end
-end
-
-function Observer:onCompleted()
-  if not self.stopped then
-    self.stopped = true
-    self._onCompleted()
-  end
-end
-
-return Observer