(self)
| 43 | child_layer: layer.Layer |
| 44 | |
| 45 | def finish_start(self) -> layer.CommandGenerator[str | None]: |
| 46 | if ( |
| 47 | self.context.options.connection_strategy == "eager" |
| 48 | and self.context.server.address |
| 49 | and self.context.server.transport_protocol == "tcp" |
| 50 | ): |
| 51 | err = yield commands.OpenConnection(self.context.server) |
| 52 | if err: |
| 53 | self._handle_event = self.done # type: ignore |
| 54 | return err |
| 55 | |
| 56 | self._handle_event = self.child_layer.handle_event # type: ignore |
| 57 | yield from self.child_layer.handle_event(events.Start()) |
| 58 | return None |
| 59 | |
| 60 | @expect(events.DataReceived, events.ConnectionClosed) |
| 61 | def done(self, _) -> layer.CommandGenerator[None]: |
no test coverage detected