Saya menggunakan perpustakaan yang mengimplementasikan permintaan REST-nya sendiri. Dibutuhkan 'permalink' dan mengeluarkan permintaan REST untuk mengambil Konten (saya memberikan tiruan dalam kode sumber untuk pengujian). Saya memiliki daftar...

Saya menggunakan lib reactive-location . Kasus penggunaan saya adalah saya memiliki aliran objek yang dipancarkan dari sesuatu yang dapat diamati. Barang-barang ini berpotensi dikeluarkan setiap beberapa jam. Segera setelah suatu item...

Hai, saya pemula untuk RxJava, dan mempelajari hal-hal yang saya lakukan pada contoh di bawah ini, ArrayListObserver.java import rx.functions.Action1; public class ArrayListObserver implements Action1<Object>{ public void call(Object...

Saya mencoba membuat Observable sedemikian rupa sehingga akan memuat beberapa data dari jaringan pada suatu interval, dan setiap kali pengguna menyegarkan halaman. Inilah inti dari apa yang saya miliki sejauh ini: PublishSubject<Long>...

Saya menggunakan vert.x sebagai server untuk menerima permintaan pencarian yang kemudian diproses di server menjadi beberapa permintaan HTTP keluar ke berbagai layanan eksternal. Untuk perilaku asinkron saya memilih untuk menggunakan RxJava...

Saya memiliki layanan sederhana ini di server saya di http://192.168.1.12:8080/api/hooray : router.route('/hooray/') .get(function (req, res) { res.status(200).send({ result: true, message: "hooray" }) }) Ini berfungsi dari...

Saya menggunakan BehaviourRelay sebagai sumber yang dapat diamati, saya suka itu akan mengeluarkan nilai cache terakhir saat berlangganan, jadi saya tidak perlu memanggil showPlayingState(mPlayStateManager.getCurrentState()) secara manual. Namun...

Saya melemparkan dua pengecualian dalam flowable, dan saya menggunakan onErrorReturn untuk menangkap pengecualian tersebut. Namun saya menemukan bahwa hanya pengecualian pertama yang tertangkap. Bagaimana cara menangkap semua pengecualian?...

Saya memiliki layanan yang telah saya daftarkan panggilan baliknya, dan sekarang saya ingin mengeksposnya sebagai Flowable dengan persyaratan/batasan tertentu: Callback penerima thread tidak boleh diblokir (pekerjaan harus diserahkan ke...

Seperti yang ditunjukkan pada kode berikut, saya menerima kesalahan terkait baris berikut, karena castingnya tidak benar .subscribe((Consumer<? super List<String>>)getAnimalsObserver()); tolong beri tahu saya cara memperbaiki...

Saya sangat baru mengenal Android dan saya butuh bantuan. Saya perlu mendapatkan restoran di dekat pengguna, dan menampilkan informasinya dalam tampilan pendaur ulang. Jadi saya menggunakan Places api: terdekat dan detailnya. Saya memiliki dua...