Zincirleme Gözlemlenebilir ve Gönderme/Gönderme Orijinal Emit'i Abone Olmak İçin Çağırmak İçin Çağrı

Question

İleti alıp kaydettiğimde, başarıya ulaştığımda veya başarısız olduğunuz bir kullanım durumum var. Mongo eklentisi Gözlemlenebilir bir şekilde döner, böylece flatmap kullanarak zincirleme yapabilirim. Sorun, gözlemlenebilir eklenti insertin sonucunu ortaya çıkarır, fakat cevap vermesi gereken ilk gözlemlenebilir mesajın orijinal mesajına ihtiyacım var. Bu nedenle, bu çalışmayı yapmak için, ilk Gözlemlenebilir'in aboneliği içindeki eki çalıştırıyorum ve ikinci abonenin içinde cevap veriyorum.

Bunu, düzlem gibi bir operatör ile daha reaktif bir şekilde gerçekleştirmeyi umuyordum. Operatörlerin listesini aradım ve aradığım şeyle ilgili hiçbir şey çıkmıyor.

eb.consumer("persister.save.event").toObservable() 
    .subscribe(msg -> { 
     mongo.insertObservable("event", (JsonObject) msg.body()) 
      .subscribe(
       res -> msg.reply(new JsonObject().put("success", true)), 
       error -> msg.fail(500, "failed to save event")); 
      }); 

Yukarıdaki kod, yapılması gerektiği gibi mi, yoksa daha iyi bir yaklaşım mı var? İki abone doğru hissetmiyor.

Answer 1

İşte iki aboneleri önlemek için yapılabilecek ne:

eb.consumer("persister.save.event").toObservable() 
    .flatMap(msg -> mongo.insertObservable("event", (JsonObject) msg.body()).map(mongoResponse -> msg)) 
    .subscribe(
      res -> msg.reply(new JsonObject().put("success", true)), 
      error -> msg.fail(500, "failed to save event")); 

hüner flatMap iç msg istediği için Mongo sonucunu map etmektir.