ฉันกำลังใช้ไลบรารีที่ใช้คำขอ REST ของตัวเอง ใช้ 'ลิงก์ถาวร' และออกคำขอ REST เพื่อดึงเนื้อหา (ฉันจัดเตรียมการเยาะเย้ยในซอร์สโค้ดสำหรับการทดสอบ) ฉันมีรายการลิงก์ถาวร และต้องการกำหนดเวลาคำขอสำหรับลิงก์แต่ละรายการและสร้างสตรีมผลลัพธ์เนื้อหา...

ฉันใช้ lib reactive-location กรณีการใช้งานของฉันคือฉันมีวัตถุมากมายที่ปล่อยออกมาจากการสังเกตได้ รายการเหล่านี้สามารถส่งออกได้ทุกสองสามชั่วโมง ทันทีที่มีการปล่อยรายการฉันต้องการรับตำแหน่งและใช้ zipWith (เท่าที่ฉันเข้าใจ)...

สวัสดี ฉันเป็นมือใหม่สำหรับ RxJava และกำลังเรียนรู้สิ่งที่ฉันทำในตัวอย่างด้านล่างนี้ ArrayListObserver.java import rx.functions.Action1; public class ArrayListObserver implements Action1<Object>{ public void call(Object element) {...

ฉันกำลังพยายามสร้าง Observable เพื่อให้โหลดข้อมูลบางส่วนจากเครือข่ายตามช่วงเวลา และเมื่อใดก็ตามที่ผู้ใช้รีเฟรชหน้าเว็บ นี่คือส่วนสำคัญของสิ่งที่ฉันมีจนถึงตอนนี้: PublishSubject<Long> refreshSubject = PublishSubject.create();...

ฉันใช้ vert.x เป็นเซิร์ฟเวอร์เพื่อรับคำขอค้นหาซึ่งจากนั้นจะถูกประมวลผลบนเซิร์ฟเวอร์ไปยังคำขอ HTTP ขาออกหลายรายการไปยังบริการภายนอกต่างๆ สำหรับพฤติกรรมแบบอะซิงโครนัส ฉันเลือกใช้ RxJava โดยใช้ไคลเอ็นต์ http ดั้งเดิมของ Vert.x...

ฉันมีบริการง่ายๆ นี้บนเซิร์ฟเวอร์ของฉันที่ http://192.168.1.12:8080/api/hooray : router.route('/hooray/') .get(function (req, res) { res.status(200).send({ result: true, message: "hooray" }) }) มันใช้งานได้จากบุรุษไปรษณีย์...

ฉันใช้ BehaviourRelay เป็นแหล่งที่มาที่สังเกตได้ ฉันชอบที่มันจะปล่อยค่าแคชล่าสุดเมื่อสมัครสมาชิก ดังนั้นฉันจึงไม่จำเป็นต้องเรียก showPlayingState(mPlayStateManager.getCurrentState()) ด้วยตนเอง อย่างไรก็ตาม...

ฉันโยนข้อยกเว้นสองข้อใน flowable และฉันใช้ onErrorReturn เพื่อตรวจจับข้อยกเว้นเหล่านั้น แต่ฉันพบว่ามีเพียงข้อยกเว้นแรกเท่านั้นที่ถูกจับได้ จะจับข้อยกเว้นทั้งหมดได้อย่างไร? Flowable.create(emitter -> { emitter.onError(new...

ฉันมีบริการที่ฉันได้ลงทะเบียนการโทรกลับ และตอนนี้ฉันต้องการแสดงเป็น Flowable โดยมีข้อกำหนด/ข้อจำกัดบางประการ: ไม่ควรบล็อกการโทรกลับเพื่อรับเธรด (งานควรถูกส่งต่อไปยังเธรด/ตัวกำหนดเวลาอื่นที่ผู้สังเกตการณ์ระบุ) ไม่ควรให้มีข้อยกเว้นใดๆ...

ดังที่แสดงในโค้ดต่อไปนี้ ฉันกำลังรับข้อผิดพลาดเกี่ยวกับบรรทัดต่อไปนี้ เนื่องจากการแคสต์ไม่ถูกต้อง .subscribe((Consumer<? super List<String>>)getAnimalsObserver()); โปรดแจ้งให้เราทราบวิธีการแก้ไขปัญหานี้ หมายเหตุ : I am...

ฉันยังใหม่กับ Android และฉันต้องการความช่วยเหลือ ฉันต้องการหาร้านอาหารใกล้กับผู้ใช้ และแสดงข้อมูลของพวกเขาในมุมมองผู้รีไซเคิล ดังนั้นฉันจึงใช้ Places api: บริเวณใกล้เคียงและรายละเอียด ฉันมีคำขอสองคำขอ...