fixed #101

Author: zookzook

lib/mongo.ex

@@ -671,7 +671,7 @@ defmodule Mongo do
 
     cmd = filter_nils(cmd)
 
-    drop = ~w(limit hint single_batch read_concern max min collation return_key show_record_id tailable no_cursor_timeout await_data batch_size projection comment max_time skip sort)a
+    drop = ~w(limit hint single_batch read_concern max min collation return_key show_record_id tailable no_cursor_timeout await_data projection comment skip sort)a
     opts = Keyword.drop(opts, drop)
     try do
       get_stream(topology_pid, cmd, opts)

test/mongo/batch_size_text.exs

@@ -0,0 +1,32 @@
+defmodule Mongo.BatchSizeTest do
+
+  require Logger
+
+  use CollectionCase
+
+  test "find, using :batch_size of 100 options", %{pid: top, catcher: catcher} do
+
+    coll = unique_collection()
+    n = 10_000
+    Mongo.delete_many(top, coll, %{})
+
+    Enum.each(1..n, fn i ->
+      Mongo.insert_one(top, coll, %{index: i}, [w: 0])
+    end)
+
+    assert {:ok, n} == Mongo.count(top, coll, %{})
+
+    assert n == top
+                |> Mongo.find(coll, %{}, batch_size: 100)
+                |> Enum.to_list()
+                |> Enum.count()
+
+    get_mores = catcher
+    |> EventCatcher.succeeded_events()
+    |> Enum.map(fn event -> event.command_name end)
+    |> Enum.filter(fn command_name -> command_name == :getMore end)
+    |> Enum.count()
+
+    assert 100 == get_mores
+  end
+end