Sha256: 62e1bd74c4b4c1d95e015a2c0e22beb4ac565014b267e48bc2760650dfcd88ba
Contents?: true
Size: 784 Bytes
Versions: 1
Compression:
Stored size: 784 Bytes
Contents
require File.expand_path("../../spec_helper", __FILE__) module JCukeForker describe StatusServer do it "can handle a message" do status = :on_worker_register worker_path = 'worker-path' raw_message = [status, worker_path].to_json # register a listener, just do an end to end test mock_listener = double(AbstractListener, :update => nil) mock_listener.should_receive(:update).with(status.to_s, worker_path) mock_io = double(IO, :sync= => nil) File.should_receive(:open).with('/tmp/in', 'r').and_return(mock_io) # expect the worker to register io_in = '/tmp/in' status_server = StatusServer.new io_in status_server.add_observer mock_listener status_server.handle_message(raw_message) end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
jcukeforker-0.3.1 | spec/jcukeforker/status_server_spec.rb |