| 59 | class TestSplit : public connector::ConnectorSplit { |
| 60 | public: |
| 61 | explicit TestSplit(uint32_t delayMs) |
| 62 | : connector::ConnectorSplit(kTestConnectorId), delayMs_{delayMs} { |
| 63 | scheduler_.start(); |
| 64 | } |
| 65 | |
| 66 | ~TestSplit() override { |
| 67 | scheduler_.shutdown(); |