rx-java

13calore

3risposta

Ho cercato le documentazioni di RxJava1 https://github.com/ReactiveX/RxJava/releases e RxJava2 https://github.com/ReactiveX/RxJava/wiki/Reactive-Streams e sembra che l'unica differenza sia che RxJava

5calore

3risposta

qual è la differenza tra RxJava e Bulloni?

Ho fatto ricerche su questo, e so che RXJava sta usando il modello osservabile, e Bull si basa su un esecutore. Quale quadro sarebbe utile per gestire le attività che devono essere eseguite in sequenz

6calore

3risposta

Come utilizzare RxJava Interval Operatore

sto imparando circa operatore RxJava, e ho trovato questi codice qui sotto non è stato stampato nulla: public static void main(String[] args) { Observable .interval(1, TimeUnit.SECONDS)

12calore

2risposta

RxJavaCallAdapterFactory non può essere convertito in fabbrica

Sto cercando di usare Retrofit 2 e RxJava seguendo la guida in questo https://inthecheesefactory.com/blog/retrofit-2.0/en Nella sezione "Integrazione RxJava con CallAdapter " spiega come utilizzare Rx

7calore

3risposta

coda come Soggetto a RxJava

Sto cercando un soggetto (o qualcosa di simile) che può: potrebbe ricevere articoli e tenerli in una coda o buffer se non ci sono abbonati Una volta che abbiamo avere un abbonato tutti gli elementi so

6calore

3risposta

Come ripulire l'incendio RxJava e dimenticare le iscrizioni?

Ho il fuoco e dimentico le operazioni che non richiedono molto tempo, ma abbastanza a lungo che ho voluto eseguirle in sottofondo in modo reattivo. Il tempo di vita è fondamentalmente mentre la connes

5calore

3risposta

Convertire un tipo di elenco in un altro RXJava? (Equivalente mappa Javascript)

Diciamo che ho un osservabile Observable<List<A>> e voglio convertirlo in un Osservabile come Observable<List<B>>. C'è un modo migliore per convertire List<A> in List<B>. L'implementazione di Javascri

16calore

6risposta

errore di cattura se retryWhen: s tentativi esaurisce

Nel documentation for RetryWhen l'esempio c'è questa: Observable.create((Subscriber<? super String> s) -> { System.out.println("subscribing"); s.onError(new RuntimeException("always fails"))

21calore

2risposta

@DELETE metodo non sta sostenendo (metodo HTTP non-corpo non può contenere @Body o @TypedOutput.)

@DELETE("/job/deletejob") Observable<JobDeleteResponseModel> jobDelete(@Body JobDeleteRequestModel model); sono sempre questo errore: Non-body HTTP method cannot contain @Body or @TypedOutput uno p

5calore

1risposta

lista filtro di oggetto in Rxjava

voglio filtrare List<Object> sulla base di interrogazione dall'utente e poi tornare List<Object> a lui/her.I trovato il modo di filtrare gli elementi ma il problema è che non so come tornare List<Obje