diff --git a/tests/runner.lua b/tests/runner.lua
index 550c477..d6a5d74 100644
--- a/tests/runner.lua
+++ b/tests/runner.lua
@@ -6,10 +6,10 @@ for _, fn in pairs({'describe', 'it', 'test', 'expect', 'spy', 'before', 'after'
 end
 
 observableSpy = function(observable)
-  local observer = Rx.Observer.create(_, function() end, _)
-  local onNext = spy(observer, '_onNext')
-  local onError = spy(observer, '_onError')
-  local onCompleted = spy(observer, '_onCompleted')
+  local onNext = spy()
+  local onError = spy()
+  local onCompleted = spy()
+  local observer = Rx.Observer.create(onNext, onError, onCompleted)
   observable:subscribe(observer)
   return onNext, onError, onCompleted
 end