| 218 | |
| 219 | |
| 220 | class AsyncMockConnection: |
| 221 | def __init__(self): |
| 222 | self.cancel_context = _CancellationContext() |
| 223 | self.more_to_come = False |
| 224 | self.id = random.randint(0, 100) |
| 225 | self.is_sdam = False |
| 226 | self.server_connection_id = random.randint(0, 100) |
| 227 | |
| 228 | def close_conn(self, reason): |
| 229 | pass |
| 230 | |
| 231 | def __aenter__(self): |
| 232 | return self |
| 233 | |
| 234 | def __aexit__(self, exc_type, exc_val, exc_tb): |
| 235 | pass |
| 236 | |
| 237 | |
| 238 | class AsyncMockPool: |