2220

Author: p

spec/integration/map_reduce_spec.rb

@@ -9,8 +9,10 @@
 
   let(:subscriber) { EventSubscriber.new }
 
+  let(:find_options) { {} }
+
   let(:operation) do
-    collection.find.map_reduce('function(){}', 'function(){}')
+    collection.find({}, find_options).map_reduce('function(){}', 'function(){}')
   end
 
   before do
@@ -23,12 +25,34 @@
   context 'read preference' do
     require_topology :sharded
 
-    let(:client) { authorized_client.with(read: {mode: :secondary_preferred }) }
+    context 'specified on client' do
+      let(:client) { authorized_client.with(read: {mode: :secondary_preferred }) }
 
-    it 'is sent' do
-      operation.to_a
+      it 'is sent' do
+        operation.to_a
+
+        event.command['$readPreference'].should == {'mode' => 'secondaryPreferred'}
+      end
+    end
+
+    context 'specified on collection' do
+      let(:collection) { client['mr_integration', read: {mode: :secondary_preferred }] }
+
+      it 'is sent' do
+        operation.to_a
+
+        event.command['$readPreference'].should == {'mode' => 'secondaryPreferred'}
+      end
+    end
+
+    context 'specified on operation' do
+      let(:find_options) { {read: {mode: :secondary_preferred }} }
+
+      it 'is sent' do
+        operation.to_a
 
-      event.command['$readPreference'].should == {'mode' => 'secondaryPreferred'}
+        event.command['$readPreference'].should == {'mode' => 'secondaryPreferred'}
+      end
     end
   end