Perform one iteration of the blocking event loop.
()
| 145 | obj.on_ready() |
| 146 | |
| 147 | def _loop_cycle(): |
| 148 | """ |
| 149 | Perform one iteration of the blocking event loop. |
| 150 | """ |
| 151 | if heartbeat_error[0] is not None: |
| 152 | raise heartbeat_error[0] |
| 153 | if qos.prev != qos.value: |
| 154 | qos.update() |
| 155 | try: |
| 156 | perform_pending_operations() |
| 157 | connection.drain_events(timeout=2.0) |
| 158 | except socket.timeout: |
| 159 | pass |
| 160 | except OSError: |
| 161 | if blueprint.state == RUN: |
| 162 | raise |
| 163 | |
| 164 | while blueprint.state == RUN and obj.connection: |
| 165 | try: |
no test coverage detected