DV
можно после filter поставить take(1)
еще есть такие штуки как takeUntil, takeWhile
скорее всего они вам и нужны
Size: a a a
2017 August 08
2017 August 10
RK
всем привет, хочу чтобы каждый элемент range приходил с задержкой
RK
Observable<Integer> observable = Observable.range(1, 10);
Consumer<Integer> action = new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
Thread.sleep(1000);
Log.d("get int", "int = " + integer);
}
};
observable.subscribe(action);
Consumer<Integer> action = new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
Thread.sleep(1000);
Log.d("get int", "int = " + integer);
}
};
observable.subscribe(action);
RK
вот такой вариант меня смущает использованием thread.sleep
RK
может как-то можно сделать через delay и concatMap?
DV
Можно cделать zip с interval
А можно и с concatMap
Observable<String> observable1 = Observable.just("A", "B", "C", "D", "E");
observable1.concatMap(new Func1<String, Observable<String»() {
@Override
public Observable<String> call(String s) {
return Observable.just(s).delay(100, TimeUnit.MILLISECONDS);
}
})
А можно и с concatMap
Observable<String> observable1 = Observable.just("A", "B", "C", "D", "E");
observable1.concatMap(new Func1<String, Observable<String»() {
@Override
public Observable<String> call(String s) {
return Observable.just(s).delay(100, TimeUnit.MILLISECONDS);
}
})
RK
Можно cделать zip с interval
А можно и с concatMap
Observable<String> observable1 = Observable.just("A", "B", "C", "D", "E");
observable1.concatMap(new Func1<String, Observable<String»() {
@Override
public Observable<String> call(String s) {
return Observable.just(s).delay(100, TimeUnit.MILLISECONDS);
}
})
А можно и с concatMap
Observable<String> observable1 = Observable.just("A", "B", "C", "D", "E");
observable1.concatMap(new Func1<String, Observable<String»() {
@Override
public Observable<String> call(String s) {
return Observable.just(s).delay(100, TimeUnit.MILLISECONDS);
}
})
Спасибо, работает с delay, а вообще подскажите какой подход предпочтительнее - использовать thread или observable delay?
DV
delay
чем меньше работы с тредами напрямую, тем лучше
чем меньше работы с тредами напрямую, тем лучше
RK
delay
чем меньше работы с тредами напрямую, тем лучше
чем меньше работы с тредами напрямую, тем лучше
благодарю за совет)
2017 August 11
YL
Всем привет, когда используем буффер перед отправкой, какой максимальный размер, и какой размер оптимальный? Когда мы используем буфер, буфер еще не заполнился или есть какие - то элементы, а нам нужно "послать" не заполненный буфер и закрыть работу, как можно реализовать , что посмотреть?
НМ
Всем привет. Каким оператором делить элементы на порции? Я пробовал буфер
DV
Всем привет. Каким оператором делить элементы на порции? Я пробовал буфер
Ну да, буффер должен подойти. Не получилось?
2017 August 12
DV
Вообще, есть RxBinding
DV
используйте Subject
DV
PublishSubject подойдет
DV
все ваши чекбоксы будут туда постить события
а он их будет уже отправлять дальше как один общий Observable
а он их будет уже отправлять дальше как один общий Observable
DV
Подумываю сделать отдельную статью с подборкой практических примеров использования RxJava
Если есть интересные примеры-ссылки, скидывайте
Если есть интересные примеры-ссылки, скидывайте
YL
так а что с буфером, ребята?