Push values to subjects by calling them as functions;

examples/subject.lua

@@ -11,5 +11,5 @@ subject:subscribe(function(x)
 end)
 
 subject:onNext(1)
-subject:onNext(2)
+subject(2)
 subject:onNext(3)

rx.lua

@@ -390,6 +390,8 @@ function Subject:onNext(value)
   end
 end
 
+Subject.__call = Subject.onNext
+
 rx = {
   Observer = Observer,
   Observable = Observable,