fixed timing problems for travis and added support for MongoDB 3.6 and 4.0

Author: zookzook

lib/mongo/cursor.ex

@@ -117,8 +117,6 @@ defmodule Mongo.Cursor do
           resume_token = stream_opts["startAfter"] || stream_opts["resumeAfter"]
           resume_token = update_resume_token(resume_token, response["postBatchResumeToken"], List.last(docs))
 
-          IO.puts "Token is #{inspect resume_token}"
-
           fun.(resume_token)
 
           change_stream = change_stream(resume_token: resume_token, op_time: op_time, cmd: cmd, on_resume_token: fun, topology_pid: topology_pid)

test/mongo/change_stream_test.exs

@@ -9,21 +9,21 @@ defmodule Mongo.ChangeStreamTest do
 
   def consumer_1(top, monitor) do
     Process.sleep(1000)
-    cursor = Mongo.watch_collection(top, "users", [], fn doc -> IO.puts("Token #{inspect doc}"); send(monitor, {:token, doc}) end, max_time: 1_000, debug: true )
+    cursor = Mongo.watch_collection(top, "users", [], fn doc -> send(monitor, {:token, doc}) end, max_time: 1_000, debug: true )
     result = cursor |> Enum.take(2) |> Enum.at(0)
     send(monitor, {:insert, result})
   end
 
   def consumer_2(top, monitor, token) do
     Process.sleep(1000)
-    cursor = Mongo.watch_collection(top, "users", [], fn doc -> IO.puts("Token #{inspect doc}"); send(monitor, {:token, doc}) end, resume_after: token, max_time: 1_000 )
+    cursor = Mongo.watch_collection(top, "users", [], fn doc -> send(monitor, {:token, doc}) end, resume_after: token, max_time: 1_000 )
     result = cursor |> Enum.take(1) |> Enum.at(0)
     send(monitor, {:insert, result})
   end
 
   def consumer_3(top, monitor, token) do
     Process.sleep(1000)
-    cursor = Mongo.watch_collection(top, "users", [], fn doc -> IO.puts("Token #{inspect doc}"); send(monitor, {:token, doc}) end, resume_after: token, max_time: 1_000 )
+    cursor = Mongo.watch_collection(top, "users", [], fn doc -> send(monitor, {:token, doc}) end, resume_after: token, max_time: 1_000 )
     result = cursor |> Enum.take(4) |> Enum.map(fn %{"fullDocument" => %{"name" => name}} -> name end)
     send(monitor, {:insert, result})
 
@@ -43,7 +43,7 @@ defmodule Mongo.ChangeStreamTest do
     spawn(fn -> consumer_1(top, me) end)
     spawn(fn -> producer(top) end)
 
-    assert_receive {:token, nil}, 5_000
+    assert_receive {:token, _}, 5_000
     assert_receive {:token, token}, 5_000
     assert_receive {:insert, %{"fullDocument" => %{"name" => "Greta"}}}, 5_000