async def subscribe_to_type_error(self, server_input_channel: connection.TextReader, server_output_channel: connection.TextWriter) -> None:
    try:
        (await self._subscribe_to_type_error(server_input_channel, server_output_channel))
    finally:
        (await self.show_status_message_to_client('Lost connection to the background Pyre Server. This usually happens when Pyre detect changes in project which it was not able to handle incrementally. A new Pyre server will be started next time you open or save a .py file', short_message='Pyre Stopped', level=lsp.MessageType.ERROR, fallback_to_notification=True))
        (await self.clear_type_errors_for_client())
        self.server_state.diagnostics = {}
async def subscribe_to_type_error(self, server_input_channel: connection.TextReader, server_output_channel: connection.TextWriter) -> None:
    try:
        (await self._subscribe_to_type_error(server_input_channel, server_output_channel))
    finally:
        (await self.show_status_message_to_client('Lost connection to the background Pyre Server. This usually happens when Pyre detect changes in project which it was not able to handle incrementally. A new Pyre server will be started next time you open or save a .py file', short_message='Pyre Stopped', level=lsp.MessageType.ERROR, fallback_to_notification=True))
        (await self.clear_type_errors_for_client())
        self.server_state.diagnostics = {}