Subject tweaks;

rx.lua

@@ -442,7 +442,7 @@ Scheduler.Cooperative = Cooperative
 local Subject = setmetatable({}, Observable)
 Subject.__index = Subject
 
-function Subject.create(initialValue)
+function Subject.create()
   local self = {
     observers = {}
   }
@@ -460,6 +460,18 @@ function Subject:onNext(value)
   end
 end
 
+function Subject:onError(message)
+  for i = 1, #self.observers do
+    self.observers[i]:onError(message)
+  end
+end
+
+function Subject:onComplete()
+  for i = 1, #self.observers do
+    self.observers[i]:onComplete()
+  end
+end
+
 Subject.__call = Subject.onNext
 
 rx = {