A class for specifying continuous paging state, only supported starting with DSE_V2.
| 448 | |
| 449 | |
| 450 | class ContinuousPagingState(object): |
| 451 | """ |
| 452 | A class for specifying continuous paging state, only supported starting with DSE_V2. |
| 453 | """ |
| 454 | |
| 455 | num_pages_requested = None |
| 456 | """ |
| 457 | How many pages we have already requested |
| 458 | """ |
| 459 | |
| 460 | num_pages_received = None |
| 461 | """ |
| 462 | How many pages we have already received |
| 463 | """ |
| 464 | |
| 465 | max_queue_size = None |
| 466 | """ |
| 467 | The max queue size chosen by the user via the options |
| 468 | """ |
| 469 | |
| 470 | def __init__(self, max_queue_size): |
| 471 | self.num_pages_requested = max_queue_size # the initial query requests max_queue_size |
| 472 | self.num_pages_received = 0 |
| 473 | self.max_queue_size = max_queue_size |
| 474 | |
| 475 | |
| 476 | class ContinuousPagingSession(object): |
no outgoing calls
no test coverage detected