anchor.diff:  
   
   %% @hidden
  -init([Connection, Database, Collection, Cursor, BatchSize, Batch]) ->
  +init([Owner, Connection, Database, Collection, Cursor, BatchSize, Batch]) ->
   	{ok, #state{
   		connection = Connection,
   		database = Database,
   		collection = Collection,
   		cursor = Cursor,
   		batchsize = BatchSize,
  -		batch = Batch
  +		batch = Batch,
  +		monitor = erlang:monitor(process, Owner)
   	}}.
   
   %% @hidden
  
positive.code: 	collection  :: atom(),
  	cursor      :: integer(),
  	batchsize   :: integer(),
  	batch       :: [bson:document()]
  }).
  
  -include ("mongo_protocol.hrl").
  
negative.code: 	{noreply, State}.
  
  %% @hidden
  handle_info({'DOWN', Monitor, process, _, _}, #state{monitor = Monitor} = State) ->
  	{stop, normal, State};
  
  handle_info(_, State) ->
  	{noreply, State}.
  
  