Raft::Node runs automatically.

celluloid · Jun 3, 2013 · 92edaef · 92edaef
1 parent c343dad
commit 92edaef
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/README.md b/README.md
@@ -53,7 +53,7 @@ comes into play.
     nodes = addresses.size.times.map do |i|
       combination = addresses.rotate(i)
       options = {listen: combination.first, peers: combination[1..-1]}
-      Raft::Node.new(listen: combination.first, peers: combination[1..-1]).tap { |node| node.run }
+      Raft::Node.new(listen: combination.first, peers: combination[1..-1])
     end
 
     # Give your nodes some time to start up.

diff --git a/lib/raft/node.rb b/lib/raft/node.rb
@@ -50,6 +50,8 @@ def initialize(options = {}, &handler)
     self.options = DEFAULT_OPTIONS.merge(options)
     self.term = 0
     self.log = Raft::Log.new
+
+    async.run
   end
 
   def run

diff --git a/test.rb b/test.rb
@@ -17,6 +17,4 @@
   supervisor.supervise(Raft::Node, options)
 end
 
-supervisor.actors.each(&:run)
-
 sleep