Wait on change pool instantiation

guard · Nov 29, 2013 · ca363ae · ca363ae
1 parent 6bb385d
commit ca363ae
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/listen/adapter/base.rb b/lib/listen/adapter/base.rb
@@ -32,6 +32,7 @@ def _directories_path
       end
 
       def _notify_change(path, options)
+        sleep 0.01 until listener.registry[:change_pool]
         listener.registry[:change_pool].async.change(path, options) if listener.listen?
       end
     end

diff --git a/lib/listen/listener.rb b/lib/listen/listener.rb
@@ -129,9 +129,8 @@ def _init_actors
       supervisor.add(Silencer, as: :silencer, args: self)
       supervisor.add(Record, as: :record, args: self)
       supervisor.pool(Change, as: :change_pool, args: self)
+
       adapter_class = Adapter.select(options)
-      p adapter_class
-      p registry[:change_pool]
       supervisor.add(adapter_class, as: :adapter, args: self)
     end