Saya sedang mengerjakan jaringan untuk aplikasi saya. Jadi saya memutuskan untuk mencoba Square's Retrofit . Saya melihat bahwa mereka mendukung sederhanaCallback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); dan RxJava
Di RxJava ada 5 penjadwal berbeda untuk dipilih: direct () : Membuat dan mengembalikan Penjadwal yang menjalankan pekerjaan segera di utas saat ini. trampoline () : Membuat dan mengembalikan Penjadwal yang antrean bekerja di utas saat ini untuk dieksekusi setelah pekerjaan saat ini selesai....
Saya ingin tahu perbedaan antara CompletableFuture, Futuredan Observable RxJava. Yang saya tahu semuanya asinkron tapi Future.get() memblokir utas CompletableFuture memberikan metode panggilan balik RxJava Observable--- mirip CompletableFuturedengan manfaat lainnya (tidak yakin) Misalnya:...
Kapan Anda menggunakan mapvs flatMapdi RxJava ? Katakanlah, misalnya, kami ingin memetakan File yang berisi JSON ke dalam Strings yang berisi JSON-- Menggunakan map, kita harus berurusan dengan Exceptionentah bagaimana. Tapi bagaimana caranya?: Observable.from(jsonFile).map(new Func1<File,...
The rxjava doc definisi switchmap agak kabur dan link ke halaman yang sama seperti flatMap. Apa perbedaan antara kedua
Apakah aliran Java 8 mirip dengan yang dapat diamati RxJava? Definisi Java 8 stream: Kelas-kelas dalam java.util.streampaket baru menyediakan Stream API untuk mendukung operasi gaya fungsional pada aliran
Saya telah melihat rx java 2 baru dan saya tidak begitu yakin saya mengerti idenya backpressurelagi ... Saya sadar bahwa kami memiliki Observableyang tidak memiliki backpressuredukungan dan Flowableyang memilikinya. Jadi berdasarkan contoh, katakanlah saya punya flowabledengan interval:...
Adakah yang bisa menjelaskan perbedaan antara Observable, Completable dan Single di RxJava dengan contoh yang jelas? Dalam skenario mana kita menggunakan salah satu dari yang
Saya mencoba meningkatkan ke Retrofit 2.0 dan menambahkan RxJava di proyek android saya. Saya melakukan panggilan api dan ingin mengambil kode kesalahan jika ada respons kesalahan dari server. Observable<MyResponseObject> apiCall(@Body body); Dan di panggilan
Saya menggunakan rxjava di aplikasi Android saya untuk menangani permintaan jaringan secara asinkron. Sekarang saya ingin mencoba lagi permintaan jaringan yang gagal hanya setelah waktu tertentu berlalu. Apakah ada cara untuk menggunakan retry () pada Observable tetapi mencoba ulang hanya...
Saya akan mengirim metode get sederhana ke server saya (ini adalah aplikasi Rails) dan mendapatkan hasilnya menggunakan RxJava dan Retrofit. Hal yang saya lakukan adalah: Antarmuka saya: public interface ApiCall { String SERVICE_ENDPOINT = "https://198.50.214.15"; @GET("/api/post")...
TL; DR Bagaimana cara mengubahnya Task.whenAll(List<Task>)menjadi RxJava? Kode saya yang ada menggunakan Bolts untuk membuat daftar tugas asinkron dan menunggu hingga semua tugas tersebut selesai sebelum melakukan langkah lain. Pada dasarnya, ini membangun List<Task>dan...