Как передать строку из AssyncTask в метод?

Question

[sur-pavel]

Всем доброго времени суток :)
В android приложении, использующем шаблон Tabbed activity, в модели добавил код для поиска в Гугле, который требует ассинхронного выполнения

public class PageViewModel extends ViewModel {

    private MutableLiveData<Integer> mIndex = new MutableLiveData<>();
    private LiveData<String> mText = Transformations.map(mIndex, new Function<Integer, String>() {
        @Override
        public String apply(Integer input) {
           
           new AsyncSearch().execute("Поисковое слово", "10");
            return ; // что возвратить???
        }
    });

    class AsyncSearch extends AsyncTask<String, Integer, String> {

        @Override
        protected String doInBackground(String... arg) {

            try {
                return GoogleSearchJava.Search(arg[0], arg[1]);

            } catch (IOException e) {
                e.printStackTrace();
                return e.getMessage() + "\n" + e.getStackTrace();
            }
        }

        @Override
        protected void onPostExecute(String s) {
            super.onPostExecute(s);
            //что здесь написать???
        }
    }
}

Как получить строку из onPostExecute() в apply()?

GoogleSearchJava

public class GoogleSearchJava {

    public static final String GOOGLE_SEARCH_URL = "https://www.google.com/search";

    public static String Search(String searchTerm, String num) throws IOException {

        String searchURL = GOOGLE_SEARCH_URL + "?q=" + searchTerm + "&num=" + num;
        //without proper User-Agent, we will get 403 error
        Document doc = Jsoup.connect(searchURL).userAgent("Mozilla/5.0").get();

        //below will print HTML data, save it to a file and open in browser to compare
        //System.out.println(doc.html());

        //If google search results HTML change the <h3 class="r" to <h3 class="r1"
        //we need to change below accordingly
        Elements results = doc.select("h3.r > a");
        StringBuilder builder = new StringBuilder();
        for (Element result : results) {
            String linkHref = result.attr("href");
            String linkText = result.text();
            builder.append(linkHref + "\n" + linkText);
            System.out.println("Text::" + linkText + ", URL::" + linkHref.substring(6, linkHref.indexOf("&")));
        }
        return builder.toString();
    }

Answer 1

[Денис Загаевский]

До чего убогий API у этой штуки...
Тебе надо написать кастомный LiveData, который будет ходить в поиск, а также использовать switchMap вместо map.
Вот тут доступно описано.
И не надо использовать асинктаски для того, чтобы ходить в сеть...

Comments

[sur-pavel]

Денис Загаевский, надо слушатели к GoogleSearchJava прикручивать?

[Денис Загаевский]

sur-pavel, можно исправить ExecutorService вместо асинктаска. Слушатели не слушатели - это уже как сделаешь.

[sur-pavel]

Денис Загаевский,
Переписал так:

private LiveData<String> mText = Transformations.map(mIndex, new Function<Integer, String>() {
        @Override
        public String apply(Integer input) {
            
            ExecutorService service = Executors.newCachedThreadPool();

            Callable<String> callableTask = () -> GoogleSearchJava.Search("Поисковое слово", "10");
            Future<String> future = service.submit(callableTask);
            String response = "";
            try {
                response = future.get();
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
            return response;
        }
    });

TextView остается пустым

UPDATE: заработало. Проблема была в фильтрации страницы html. Executor помог.

[Денис Загаевский]

sur-pavel, наверняка в logcat стектрейс. Не надо глотать исключения. Объясни, плз, нахрена тут асинхронность, если ты всё равно блокирующе берешь из фьючи значение? Сделай кастомную лайвдату.

[sur-pavel]

Денис Загаевский, я уже третий день пытаюсь что-то сделать, но ничего не получается. Да, я тупой. Подскажите, пожалуйста, хоть как схематично должна выглядеть кастомная лайвдата.
Так?

public class SearchLiveData extends LiveData<String> {

    private static SearchLiveData instance;
    private int index;
    public static SearchLiveData getInstance(int index) {
        if (instance == null) {
            instance = new SearchLiveData(index);
        }
        return instance;
    }
    private SearchLiveData(int index){
        this.index = index;
    }

    
    @Override
    public void postValue(String value) {
        try {
            value = GoogleSearchJava.Search(index + "Поиск", "10");
        } catch (IOException e) {
            e.printStackTrace();
            value = e.getMessage() + "\n" + e.getStackTrace();
        }
        super.postValue(value);
    }
}

а в PageViewModel?

public class PageViewModel extends ViewModel {

    private MutableLiveData<Integer> mIndex = new MutableLiveData<>();
    private SearchLiveData mText = (SearchLiveData) Transformations.switchMap(mIndex, new Function<Integer, LiveData<String>>() {
        @Override
        public LiveData<String> apply(Integer input) {
            return SearchLiveData.getInstance(input);
        }
    });

    public void setIndex(int index) {
        mIndex.setValue(index);
    }

    public LiveData<String> getText() {
        return mText;
    }
}

Да, этот код нерабочий. Но как его исправить?

[sur-pavel]

Денис Загаевский, Если в модели использовать

private LiveData<String> mText = Transformations.map(mIndex, new Function<Integer, String>() {
        @Override
        public String apply(Integer input) {            
            ExecutorService service = Executors.newCachedThreadPool();
            Callable<String> callableTask = () -> GoogleSearchJava.Search("Поисковое слово", "10");
            Future<String> future = service.submit(callableTask);            
            try {
                Log.println(Log.DEBUG,"GoogleSearch",future.get());
                return future.get();
            } catch (InterruptedException | ExecutionException e) {
                Log.println(Log.ERROR, "GoogleSearch", e.getMessage() + "\n" + e.getStackTrace());
                return e.getMessage() + "\n" + e.getStackTrace();
            }
        }
    });

TextView все равно пустой и в логах тишина

[Денис Загаевский]

sur-pavel, зачем ты postValue переопределил? По ссылке из ответа есть конкретный пример, сделай как там.

[sur-pavel]

Денис Загаевский, этот?

public class LocationLiveData extends LiveData<Location> {
 
   LocationService.LocationListener locationListener = new LocationService.LocationListener() {
       @Override
       public void onLocationChanged(Location location) {
           setValue(location);
       }
   };
 
   @Override
   protected void onActive() {
       LocationService.addListener(locationListener);
   }
 
   @Override
   protected void onInactive() {
       LocationService.removeListener(locationListener);
   }
 
}

Но зачем мне слушатели, если мне просто нужно сделать поиск? Можно, пожалуйста, хотя бы пару строк кода. Ваши ответы для меня слишком неопределенные.

[Денис Загаевский]

sur-pavel, слушатели тебе затем, что поиск надо делать асинхронно. По окончанию поиска нужно вызвать этот слушатель.