(observable, timeout)
| 452 | |
| 453 | |
| 454 | def wait_observable_close_notification(observable, timeout): |
| 455 | close_condition = threading.Event() |
| 456 | observable.subscribe_on_close(lambda: close_condition.set()) |
| 457 | close_condition.wait(timeout) |
| 458 | |
| 459 | |
| 460 | def mock_request_handler(*, arguments: dict = None, method='GET', headers=None, previous_request=None): |
no test coverage detected