我的任务是这样实现的:
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)