(client)
| 41 | |
| 42 | |
| 43 | def get_executors(client): |
| 44 | executors = [] |
| 45 | for server in client._topology._servers.values(): |
| 46 | executors.append(server._monitor._executor) |
| 47 | executors.append(server._monitor._rtt_monitor._executor) |
| 48 | executors.append(client._kill_cursors_executor) |
| 49 | executors.append(client._topology._Topology__events_executor) |
| 50 | return [e for e in executors if e is not None] |
| 51 | |
| 52 | |
| 53 | class TestMonitor(IntegrationTest): |
no test coverage detected