Sha256: 8386ae0d61c2829b3398fd7879ee38278001b6d83239b8b8151a145020de5116
Contents?: true
Size: 1.41 KB
Versions: 21
Compression:
Stored size: 1.41 KB
Contents
class Arachni::RPC::Server::Dispatcher
class Service::Echo < Service
private :instances
public :instances
def test_dispatcher
dispatcher.class == Arachni::RPC::Server::Dispatcher
end
def test_opts
dispatcher.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( url: "http://stuff.com/#{i}") { |p| iterator.next }
end
true
end
def test_iterator_for
iterator_for( instances ).class == Arachni::Reactor::Iterator
end
def test_connect_to_dispatcher( &block )
connect_to_dispatcher( options.datastore.dispatcher_url ).alive? { |b| block.call b }
end
def test_connect_to_instance( *args, &block )
connect_to_instance( *args ).framework.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
21 entries across 21 versions & 1 rubygems