@@ -31,13 +31,10 @@ class CommandCursor(object):
31
31
"""A cursor / iterator over command cursors."""
32
32
_getmore_class = _GetMore
33
33
34
- def __init__ (self , collection , cursor_info , address , retrieved = 0 ,
34
+ def __init__ (self , collection , cursor_info , address ,
35
35
batch_size = 0 , max_await_time_ms = None , session = None ,
36
36
explicit_session = False ):
37
- """Create a new command cursor.
38
-
39
- The parameter 'retrieved' is unused.
40
- """
37
+ """Create a new command cursor."""
41
38
self .__sock_mgr = None
42
39
self .__collection = collection
43
40
self .__id = cursor_info ['id' ]
@@ -297,7 +294,7 @@ def __exit__(self, exc_type, exc_val, exc_tb):
297
294
class RawBatchCommandCursor (CommandCursor ):
298
295
_getmore_class = _RawBatchGetMore
299
296
300
- def __init__ (self , collection , cursor_info , address , retrieved = 0 ,
297
+ def __init__ (self , collection , cursor_info , address ,
301
298
batch_size = 0 , max_await_time_ms = None , session = None ,
302
299
explicit_session = False ):
303
300
"""Create a new cursor / iterator over raw batches of BSON data.
@@ -310,7 +307,7 @@ def __init__(self, collection, cursor_info, address, retrieved=0,
310
307
"""
311
308
assert not cursor_info .get ('firstBatch' )
312
309
super (RawBatchCommandCursor , self ).__init__ (
313
- collection , cursor_info , address , retrieved , batch_size ,
310
+ collection , cursor_info , address , batch_size ,
314
311
max_await_time_ms , session , explicit_session )
315
312
316
313
def _unpack_response (self , response , cursor_id , codec_options ,
0 commit comments