Свързани въпроси 'rx-java'
RxJava Timer Наблюдава се, но изчакайте да завърши
Имам нещо подобно:
return Observable.timer(2, TimeUnit.SECONDS)
.flatMap(integer -> captureList.getLatestCaptureCut()) #1
.flatMap(vp::processVideo) #2
.observeOn(AndroidSchedulers.mainThread())...
1451 изгледи
schedule
19.09.2022
RXSwift Zip оператор N елементи чрез изброим
Използвам оператора zip на RxSwift, за да комбинирам Observable елемента. Искам да комбинирам повече от 8 (максимумът, поддържан в момента). RxSwift има ли оператор zip , подобен на RxJava? - Документация за RxJava Zip оператор
949 изгледи
schedule
15.09.2022
Retrofit2 десериализация/преобразуване на неосновна нишка с помощта на rxjava
Вече споменах този отговор и изглежда, че е свързан с Retrofit v1.
Цел -> Да се намали времето за студен старт, като накарате ObjectMapper да работи върху неосновна нишка. Това изображение показва проследяване на стека, което се случва в...
754 изгледи
schedule
20.09.2022
Защо получавам android.os.TransactionTooLargeException в моето приложение за Android, написано на Kotlin/rxJava, когато излизам от приложението? (при изход/при пауза)?
Работя върху приложение в Kotlin/rxJava и от известно време се боря с грешка.
Всеки път, когато изляза от приложението, получавам изскачащ прозорец, в който пише: „За съжаление, AppName спря.“.
Получавам тази грешка в конзолата:...
2222 изгледи
schedule
15.09.2022
RxJava 2.0 - обработка на ресурси за неуловена абонатна грешка в publish().refCount()
Аз съм доста нов в RxJava и - както много други - се опитвам да се ориентирам в обработката на изключения. Прочетох доста публикации онлайн (напр. тази дискусия тук как да се справя с изключения, хвърлени от наблюдателя onNext ) и мисля , че...
149 изгледи
schedule
21.09.2022
RxJava Асинхронно отстраняване на отскок
Използвайки операции на RxJava, възможно ли е да "игнорирате" елементи, които са били обработени в низходящия поток, ако възходящият поток излъчва нови елементи?
например
Observable.create(...)
.flatMap(...) // 30 seconds to process...
37 изгледи
schedule
25.09.2022
Rx Android - изчакайте отговор на сървъра
Използвам RxJava и Retrofit в приложение за Android, за да получа данни от сървъра. Имам тестова дейност с този код.
String text;
@Override
protected void onCreate(Bundle savedInstanceState) {...
947 изгледи
schedule
04.10.2022
Observer.onError се задейства непоследователно
Използвам Retrofit за достъп до моя API, както следва:
public interface UserService {
...
@POST("/user/login")
public Observable<User> register(@Body() User user);
}
Ето как влизам в своя API:...
5549 изгледи
schedule
24.11.2022
RxJava верижни наблюдаеми и обработка на грешки (разпространение на персонализирани изключения)
Имам 5 Observable , които са свързани с flatMap . В случай че първите четири Observable произвеждат Exception , искам да разпространя различен тип Exception към петия.
Как се постига?
Благодаря.
P.S. Измислих това все още...
12115 изгледи
schedule
26.10.2022
Консумиране на стойности, излъчвани едновременно от наблюдател
Уча реактивно програмиране с RxJava и искам да консумирам излъчени стойности едновременно без блокиране в една нишка за изпълнение.
Observable
.interval(50, TimeUnit.MILLISECONDS)
.take(5)
.subscribe(new...
495 изгледи
schedule
01.12.2023
RxJava: как да емулирам сLatestFrom?
Според документацията, withLatestFrom липсва в изпълнението на Java (което е леко различно от combineLatest ). Някаква идея как да емулирам това?
2381 изгледи
schedule
28.11.2023
rxjava добавя елементи след създаването на наблюдаем
Току-що започнах да използвам rxjava и се забих. Може би не използвам rxjava по правилния начин, но трябва да добавя елементи към Observable , след като е бил създаден. Така че разбирам, че можете просто да се обадите на Observable.just("Some",...
11811 изгледи
schedule
27.11.2022
Queing независими наблюдаеми
Възможно ли е да поставите на опашка множество наблюдаеми, така че да се изпълняват един след друг, без да се познават?
Да кажем, че имам 3 различни Observable в 3 различни класа и/или нишки. Всички те представляват различно искане. Редът на...
67 изгледи
schedule
26.10.2023
Разлика между потоците на Java 8 и наблюдаемите RxJava
Java 8 потоците подобни ли са на наблюдаемите RxJava?
Дефиниция на потока на Java 8:
Класовете в новия пакет java.util.stream предоставят Stream API за поддръжка на операции във функционален стил върху потоци от елементи.
46731 изгледи
schedule
24.12.2023
Количеството изпълнения на flatMap зависи от привличането на наблюдателя, докато е необходимо единично
Имам механизъм за насочено уведомяване (PublishSubject), който задейства логиката на http заявка (flatMap). Основният сценарий е, че когато пристигне натискане, се прави едно http извикване и резултатите се разпространяват до множество наблюдатели....
180 изгледи
schedule
14.01.2024
RxJava android не работи и не може да компилира код
Искам да науча RXjava за android, така че направих следното:
1) Изтеглих jar файла на rxandroid-0.24.jar, rxandroid-framework-0.24.jar 2) добавих файлове към папката libs в android studio 3) добавих зависимост от lib към android studio, моля,...
2259 изгледи
schedule
09.02.2024
RxJava каква е разликата между стартиране и създаване?
Гледам тези два оператора, които изглежда вършат една и съща работа:
http://reactivex.io/documentation/operators/start.html http://reactivex.io/documentation/operators/create.html
Create само по-новата версия на start ли е? Защото аз също...
176 изгледи
schedule
11.11.2022
RxJava - cache() същото ли е като replay()?
Чудех се дали има оператор cache() , който може да кешира x брой емисии, но също така да ги изтече след определен интервал от време (напр. 1 минута). Търсех нещо като...
Observable<ImmutableList<MyType>> cachedList = otherObservable...
9970 изгледи
schedule
01.12.2023
RxAndroid: Синхронно изпълнение на наблюдаем
Започвам с Rx с RxAndroid и искам да изброя името на потребителя на GitHub чрез неговия API с Retrofit. Всяка заявка за API носи 100 потребители, след като обработя всички потребители, искам да получа следващите 100, но не мога да осъзная как да...
2773 изгледи
schedule
03.03.2024
Ретрофит/Rxjava и базирани на сесия услуги
Внедрявам услуги, базирани на сесии. Всички заявки трябва да бъдат абонирани с параметър за сесия на бисквитка, който от своя страна се извлича с отделен API за почивка. Така че основният работен процес би бил да получите сесийната бисквитка и да...
5080 изгледи
schedule
18.04.2024
