(self, options=None, **kwargs)
| 458 | """A server for testing DoExchange.""" |
| 459 | |
| 460 | def __init__(self, options=None, **kwargs): |
| 461 | super().__init__(**kwargs) |
| 462 | self.options = options |
| 463 | |
| 464 | def do_exchange(self, context, descriptor, reader, writer): |
| 465 | assert reader.stats.num_messages == 0 |