1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
class CommandCursor:
def __init__(self, collection, curser_info=None, address=None, retrieved=0):
self._collection = iter(collection)
self._id = None
self._address = address
self._data = {}
self._retrieved = retrieved
self._batch_size = 0
self._killed = self._id == 0
@property
def address(self):
return self._address
def close(self):
pass
def batch_size(self, batch_size):
return self
@property
def alive(self):
return True
def __iter__(self):
return self
def next(self):
return next(self._collection)
__next__ = next
def __enter__(self):
return self
def __exit__(self, exc_type, exc_val, exc_tb):
return
|
