async def _subscribe_to_type_error(self, server_input_channel: connection.TextReader, server_output_channel: connection.TextWriter) -> None:
    subscription_name = f'persistent_{os.getpid()}'
    (await server_output_channel.write(f'''["SubscribeToTypeErrors", "{subscription_name}"]
'''))
    async with _read_server_response(server_input_channel) as first_response:
        initial_type_errors = incremental.parse_type_error_response(first_response)
        self.update_type_errors(initial_type_errors)
        (await self.show_type_errors_to_client())
    while True:
        async with _read_server_response(server_input_channel) as raw_subscription_response:
            subscription_response = parse_subscription_response(raw_subscription_response)
            if (subscription_name == subscription_response.name):
                (await self._handle_subscription_body(subscription_response.body))
async def _subscribe_to_type_error(self, server_input_channel: connection.TextReader, server_output_channel: connection.TextWriter) -> None:
    subscription_name = f'persistent_{os.getpid()}'
    (await server_output_channel.write(f'["SubscribeToTypeErrors", "{subscription_name}"]
'))
    async with _read_server_response(server_input_channel) as first_response:
        initial_type_errors = incremental.parse_type_error_response(first_response)
        self.update_type_errors(initial_type_errors)
        (await self.show_type_errors_to_client())
    while True:
        async with _read_server_response(server_input_channel) as raw_subscription_response:
            subscription_response = parse_subscription_response(raw_subscription_response)
            if (subscription_name == subscription_response.name):
                (await self._handle_subscription_body(subscription_response.body))