@connection.asynccontextmanager
async def _read_server_response(server_input_channel: connection.TextReader) -> AsyncIterator[str]:
    try:
        raw_response = (await server_input_channel.read_until(separator='\n'))
        (yield raw_response)
    except incremental.InvalidServerResponse as error:
        LOG.error(f'Pyre server returns invalid response: {error}')
@connection.asynccontextmanager
async def _read_server_response(server_input_channel: connection.TextReader) -> AsyncIterator[str]:
    try:
        raw_response = (await server_input_channel.read_until(separator='\n'))
        (yield raw_response)
    except incremental.InvalidServerResponse as error:
        LOG.error(f'Pyre server returns invalid response: {error}')