Sha256: 19ced37eb23dcd826f3a7a38b9a2a1811fb9d626b7a276fa2a07bc0dae562cee
Contents?: true
Size: 1.34 KB
Versions: 22
Compression:
Stored size: 1.34 KB
Contents
class Cuboid::RPC::Server::Agent
class Service::Echo < Service
private :instances
public :instances
def test_agent
agent.class == Cuboid::RPC::Server::Agent
end
def test_opts
agent.instance_eval{ @options } == options
end
def test_node
node.class == Node
end
def test_map_instances( &block )
each = proc do |instance, iterator|
iterator.return [instance.url, instance.token]
end
after = proc { |i| block.call Hash[i] }
map_instances( each, after )
end
def test_each_instance
i = 0
each_instance do |instance, iterator|
i += 1
instance.options.set( authorized_by: "test#{i}@test.test") { |p| iterator.next }
end
true
end
def test_iterator_for
iterator_for( instances ).class == Raktr::Iterator
end
def test_connect_to_agent( url, &block )
connect_to_agent( url ).alive? { |b| block.call b }
end
def test_connect_to_instance( *args, &block )
connect_to_instance( *args ).busy?{ |b| block.call !!b }
end
def test_defer( *args, &block )
defer do
block.call args
end
end
def test_run_asap( *args, &block )
run_asap { block.call args }
end
def echo( *args )
args
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems