Farsiyan V. HomeWork_06 RX #74
Conversation
| emitter.onNext(success) | ||
| }, BackpressureStrategy.BUFFER) | ||
| .distinctUntilChanged() | ||
| .debounce(2000, TimeUnit.MILLISECONDS) |
There was a problem hiding this comment.
Дебаунс мне кажется совсем не для этого, почему интервал как в презенетере не подошел?
| @@ -25,6 +26,10 @@ class LocalCatFactsGenerator( | |||
| */ | |||
| fun generateCatFactPeriodically(): Flowable<Fact> { | |||
| val success = Fact(context.resources.getStringArray(R.array.local_cat_facts)[Random.nextInt(5)]) | |||
| return Flowable.empty() | |||
| return Flowable.create<Fact?>({ emitter -> | |||
There was a problem hiding this comment.
Я думаю можно просто fromCallable взять
|
|
||
| class CatsViewModel( | ||
| catsService: CatsService, | ||
| localCatFactsGenerator: LocalCatFactsGenerator, | ||
| val catsService: CatsService, |
| getFacts(context) | ||
| } | ||
|
|
||
| fun getFacts(context: Context) { |
There was a problem hiding this comment.
В конструкторе же есть контекст, может тогда проще его сделать проперти?
| val observable = Observable.interval(2, TimeUnit.SECONDS) | ||
| .subscribeOn(Schedulers.io()) | ||
| .flatMap { catsService.getCatFact() } | ||
| .doOnError { |
There was a problem hiding this comment.
Это сайд-оператор, возьми лучше тот который в цепочке участвует и не придется 2 подписки делать
There was a problem hiding this comment.
если имеется ввиду лямбда t -> { } которая в subscribe методе, при retry() дело до него не доходит и он не вызывается
| fun generateCatFactWhileError() { | ||
| localCatFactsGenerator.generateCatFact() | ||
| .subscribeOn(AndroidSchedulers.mainThread()) | ||
| .subscribe(object: SingleObserver<Fact> { |
There was a problem hiding this comment.
Если ты реализовал только onSuccess, может не брать SingleObserver а просто лямбду передать в subscribe?
No description provided.