我的任务是这样实现的:
class MyTask
@queue = :queue_name
include BaseTask
end
module BaseTask
include Observable
def perform
add_observer(MyObserver.new)
...
changed
notify_observers
end
end
我有一个 Resque 任务,它include Observable
使用perform
方法调用add_observer
,changed
和notify_observers
. BaseTask
我该如何测试RSpec
?我初始化MyTask
并调用了task.perform
. 我试过了,,,,但Observable.should_receive(:add_observer)
他们不工作?MyTask.any_instance.should_receive(:add_observer)
BaseTask.should_receive(:add_observer)