Результаты поиска по запросу "rx-java"

2 ответа

 может быть полезным (по крайней мере, первые 15 минут)

ользую RxJava для обработки некоторых уведомлений, которые мы извлекаем из очереди. Казалось, что RxJava отлично работает с простым рабочим процессом, теперь, когда появляются новые требования, этот процесс усложняется с появлением ...

1 ответ

 вызовет новый буфер с самым первым пустым буфером.

я есть наблюдаемая, которая излучает большое количество данных, таких как [1,1,1,2,2,2,3,3,1,1,5,5 ......] В RxJava мы можем использоватьdistinctUntilChanged () [http://reactivex.io/documentation/operators/distinct.html]чтобы получить отдельные ...

1 ответ

Я только что видел это! Посмотрим позже.

аюсь получить снимок GoogleMap (из MapView) в фоновом режиме, вернуть его с обратным вызовом и показать его в ImageView. При этом я стараюсь сделать получение снимка как можно более независимым от макета (поэтому стараюсь не добавлять MapView в ...

ТОП публикаций

0 ответов

 может быть передан для получения дополнительной информации.

у сделать что-то после небольшой задержки: public void notifyMe() { Single .timer(500, TimeUnit.MILLISECONDS) .subscribeOn(Schedulers.io()) .subscribe(ignore -> service.notifyMe())); }Теперь у меня есть предупреждение:"The result of subscribe is ...

0 ответов

http://reactivex.io/documentation/operators/zip.html

емаУ меня есть два Apis. Api 1 дает мне список предметов, а Api 2 дает мне более подробную информацию для каждого из предметов, которые я получил от Api 1. То, как я его решил, приводит к плохой производительности. ВопросЭффективное и быстрое ...

1 ответ

 Вот.

м, у меня есть такая деятельность: public class TestActivity extends AppCompatActivity { @Override public void onCreate(@Nullable Bundle savedInstanceState) { super.onCreate(savedInstanceState); final TextView countdown = new TextView(this); ...

1 ответ

Я попробовал сейчас, и ошибка заняла 22 секунды, это не сработало. TNX в любом случае.

ользую Retrofit + Rxjava для получения списка сущностей с сервера, по моей схеме, когда задача не выполняется, сначала она проверяет подключение к Интернету, а затем проверяет соединение с сервером вdoOnError методObservable. Когда Клиент не ...

3 ответа

 (позволяет пройти 5 объектов)

чистый способ создания разрушаемых объектов в линии.kotlin.Pair а такжеkotlin.Triple охватывать множество вариантов использования, но иногда есть и другие объекты, которые необходимо передать. Один пример использования RXzip функция, в которой ...

1 ответ

для диалога мне нужен контекст активности.

чаю Android и следую некоторым руководствам по Retrofit2 с RxJava и Dagger2. Теперь я хочу, чтобы не иметь дело с подключением к интернету. Я нашел этоответ,...

1 ответ

да ты прав. моя вина