From ca63f97f8f44d5c768d36c2793b4c1bb7b44381d Mon Sep 17 00:00:00 2001
From: Yossef Mendelssohn <ymendel@pobox.com>
Date: Sat, 14 Jun 2008 00:37:11 -0500
Subject: [PATCH] Continuing initialization refactoring, creating fs event
 stream.

The actual fs event stream itself (from OSX.FSEventStreamCreate) is now made outside of initialization. This should free initialization to be simple.
---
 lib/fsevents/stream.rb |  5 +++
 spec/stream_spec.rb    | 91 ++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 96 insertions(+)

diff --git a/lib/fsevents/stream.rb b/lib/fsevents/stream.rb
index f9ea403..888885d 100644
--- a/lib/fsevents/stream.rb
+++ b/lib/fsevents/stream.rb
@@ -26,6 +26,11 @@ def initialize(*paths, &callback)
       raise StreamError, 'Unable to create FSEvents stream.' unless @stream
     end
     
+    def create
+      @stream = OSX.FSEventStreamCreate(allocator, stream_callback, context, paths, since, latency, flags)
+      raise StreamError, 'Unable to create FSEvents stream.' unless @stream
+    end
+    
     def stream_callback
       lambda do |stream, context, event_count, paths, event_flags, event_IDs|
         paths.regard_as('*')
diff --git a/spec/stream_spec.rb b/spec/stream_spec.rb
index 04cb6bb..f7f3e27 100644
--- a/spec/stream_spec.rb
+++ b/spec/stream_spec.rb
@@ -271,6 +271,97 @@
     end
   end
   
+  it 'should create a stream' do
+    @stream.should respond_to(:create)
+  end
+  
+  describe 'when creating the stream' do
+    before :each do
+      @args = {}
+      [:allocator, :context, :paths, :since, :latency, :flags].each do |arg|
+        val = stub(arg.to_s)
+        
+        @stream.stubs(arg).returns(val)
+        @args[arg] = val
+      end
+      
+      @arg_placeholders = Array.new(7) { anything }
+      
+      @stream_val = stub('stream')
+      OSX.stubs(:FSEventStreamCreate).returns(@stream_val)
+    end
+    
+    it 'should create an FSEvent stream' do
+      OSX.expects(:FSEventStreamCreate).returns(@stream_val)
+      @stream.create
+    end
+    
+    it 'should pass the allocator' do
+      args = @arg_placeholders
+      args[0] = @args[:allocator]
+      OSX.expects(:FSEventStreamCreate).with(*args).returns(@stream_val)
+      @stream.create
+    end
+    
+    it 'should pass the stream callback' do
+      # stream_callback returns a different proc every time it's called
+      @stream.stubs(:stream_callback).returns(stub('stream callback'))
+      args = @arg_placeholders
+      args[1] = @stream.stream_callback
+      OSX.expects(:FSEventStreamCreate).with(*args).returns(@stream_val)
+      @stream.create
+    end
+    
+    it 'should pass the context' do
+      args = @arg_placeholders
+      args[2] = @args[:context]
+      OSX.expects(:FSEventStreamCreate).with(*args).returns(@stream_val)
+      @stream.create
+    end
+    
+    it 'should pass the paths' do
+      args = @arg_placeholders
+      args[3] = @args[:paths]
+      OSX.expects(:FSEventStreamCreate).with(*args).returns(@stream_val)
+      @stream.create
+    end
+    
+    it "should pass 'since' (event ID)" do
+      args = @arg_placeholders
+      args[4] = @args[:since]
+      OSX.expects(:FSEventStreamCreate).with(*args).returns(@stream_val)
+      @stream.create
+    end
+    
+    it 'should pass the latency' do
+      args = @arg_placeholders
+      args[5] = @args[:latency]
+      OSX.expects(:FSEventStreamCreate).with(*args).returns(@stream_val)
+      @stream.create
+    end
+    
+    it 'should pass the flags' do
+      args = @arg_placeholders
+      args[6] = @args[:flags]
+      OSX.expects(:FSEventStreamCreate).with(*args).returns(@stream_val)
+      @stream.create
+    end
+    
+    it 'should store the stream' do
+      @stream.create
+      @stream.stream.should == @stream_val
+    end
+    
+    it 'should raise a StreamError exception if the stream could not be created' do
+      OSX.stubs(:FSEventStreamCreate).returns(nil)
+      lambda { @stream.create }.should raise_error(FSEvents::Stream::StreamError)
+    end
+    
+    it 'should not raise a StreamError exception if the stream could be created' do
+      lambda { @stream.create }.should_not raise_error(FSEvents::Stream::StreamError)
+    end
+  end
+  
   it 'should have a stream callback' do
     @stream.should respond_to(:stream_callback)
   end