Setup RPC server and client for tests.
(self)
| 648 | class TestRpcAsync: |
| 649 | # Use setup_method/teardown_method for pytest class-based setup/teardown |
| 650 | def setup_method(self): |
| 651 | """Setup RPC server and client for tests.""" |
| 652 | self.app = TestApp() |
| 653 | self.server = RPCServer(self.app, num_workers=2, async_run_task=True) |
| 654 | self.server.bind("tcp://127.0.0.1:0") # Use random port |
| 655 | self.server.start() |
| 656 | # Get actual address after binding |
| 657 | address = f"tcp://127.0.0.1:{self.server.address.split(':')[-1]}" |
| 658 | self.client = RPCClient(address) |
| 659 | |
| 660 | def teardown_method(self): |
| 661 | self.server.shutdown() |