(self, mock)
| 95 | _consumer.strategies = self.obj.strategies |
| 96 | |
| 97 | def timeout_then_error(self, mock): |
| 98 | |
| 99 | def first(*args, **kwargs): |
| 100 | mock.side_effect = socket.error() |
| 101 | raise socket.timeout() |
| 102 | mock.side_effect = first |
| 103 | |
| 104 | def close_then_error(self, mock=None, mod=0, exc=None): |
| 105 | mock = Mock() if mock is None else mock |
no outgoing calls
no test coverage detected