Merge pull request #5 from johnfoconnor/master

fix typos

rx.lua

@@ -645,7 +645,7 @@ function Observable:distinctUntilChanged(comparator)
     end
 
     local function onError(message)
-      return observer:onError(onError)
+      return observer:onError(message)
     end
 
     local function onCompleted()
@@ -707,7 +707,7 @@ function Observable:filter(predicate)
     end
 
     local function onCompleted()
-      return observer:onCompleted(e)
+      return observer:onCompleted()
     end
 
     return self:subscribe(onNext, onError, onCompleted)
@@ -729,7 +729,7 @@ function Observable:find(predicate)
     end
 
     local function onError(message)
-      return observer:onError(e)
+      return observer:onError(message)
     end
 
     local function onCompleted()
@@ -1011,7 +1011,7 @@ function Observable:reject(predicate)
     end
 
     local function onCompleted()
-      return observer:onCompleted(e)
+      return observer:onCompleted()
     end
 
     return self:subscribe(onNext, onError, onCompleted)

src/operators/distinctUntilChanged.lua

@@ -21,7 +21,7 @@ function Observable:distinctUntilChanged(comparator)
     end
 
     local function onError(message)
-      return observer:onError(onError)
+      return observer:onError(message)
     end
 
     local function onCompleted()

src/operators/filter.lua

@@ -19,7 +19,7 @@ function Observable:filter(predicate)
     end
 
     local function onCompleted()
-      return observer:onCompleted(e)
+      return observer:onCompleted()
     end
 
     return self:subscribe(onNext, onError, onCompleted)

src/operators/find.lua

@@ -16,7 +16,7 @@ function Observable:find(predicate)
     end
 
     local function onError(message)
-      return observer:onError(e)
+      return observer:onError(message)
     end
 
     local function onCompleted()

src/operators/reject.lua

@@ -20,7 +20,7 @@ function Observable:reject(predicate)
     end
 
     local function onCompleted()
-      return observer:onCompleted(e)
+      return observer:onCompleted()
     end
 
     return self:subscribe(onNext, onError, onCompleted)