     connectResolveCallbacks[1](mockDb)
     streamSpy.calledOnce.should.be.true
 
-    mongo.MongoClient.connectAsync = replacedConnectAsync
+    mongo.connectAsync = replacedConnectAsync
 
   it 'should defer .insert() calls until connection established', ->
     connectResolveCallbacks = []
-    replacedConnectAsync = mongo.MongoClient.connectAsync
-    mongo.MongoClient.connectAsync = sinon.stub().returns
+    replacedConnectAsync = mongo.connectAsync
+    mongo.connectAsync = sinon.stub().returns
       then: (cb) -> connectResolveCallbacks.push cb
       isPending: -> true
     mockDb =

    connectResolveCallbacks[1](mockDb)
    mockCollection.insertAsync.calledOnce.should.be.true

    mongo.MongoClient.connectAsync = replacedConnectAsync


  it 'should defer .find() calls until connection established', ->
    connectResolveCallbacks = []
    replacedConnectAsync = mongo.connectAsync
    mongo.connectAsync = sinon.stub().returns
      then: (cb) -> connectResolveCallbacks.push cb
      isPending: -> true
    mockDb =
