reactive-programming

    0熱度

    1回答

    我有對象的這樣一個數組: [{ "message": { "from": "one", "body": "lorem" } }, { "message": { "from": "two", "body": "ipsum" } }, { "point": { "topic": "lorem",

    0熱度

    1回答

    我有一個與條件面板的問題。我想在sidebarPanel中顯示DateRange或SliderInput,具體取決於RadioButton中的選擇選項,它也位於sidebarPanel中。 如果您嘗試運行下面的例子將失敗,並以下錯誤信息: 錯誤:由多個實際 參數匹配的正式說法「條件」 如果您註釋掉任何在這兩個條件中,您可以看到example變量的值爲a或b,具體取決於所選的選項。 我很確定我錯過了

    0熱度

    1回答

    我有一個活動,從網絡加載數據,並有一個「重試」按鈕,如果請求失敗,只是重新進行相同的網絡調用。這是簡化的代碼: public class MainActivity extends Activity { private DisposableObserver<Data> disposableObserver; @Override public void onCrea

    0熱度

    1回答

    我想弄清楚如何在一個彈簧5 ReactiveCrudRepository在火災和遺忘模式中保存(例如mongo)。 代碼很簡單 public Mono<MyObject> saveObject(Mono<MyObject> mono) { return mono.flatMap(objectRepository::save); } 事實上我並不需要閱讀返回值,並在反應的世界裏,讀取

    -1熱度

    1回答

    我正在做Akka和Scala的第一步。對於這個問題,scala並不重要,也可以是java。 我的小程序: 收集一些數據(A) 做一些計算(B) 並將結果保存在一個表(C) 我見兩種或更好的三種不同的方法來設計我的演員。 (A)發送消息爲(B)的演員,但那麼我們就可以不同的方式之間進行選擇: (B)發送答案回(A) (B)發送給第三演員的持久性(C) ((B)將數據存儲在自己的DB) 哪一個是最好的

    0熱度

    1回答

    我有一個元素列表,我想從該列表中一次處理n個元素。我怎樣才能以RX的方式做到這一點? 我看了一下take算子,但它只取第n個或最後n個元素。我需要處理列表中的所有元素,但一次處理n個元素。 理想情況下,我應該從一個更大的列表中得到多個大小爲n的列表。

    2熱度

    1回答

    我有一個多級層次結構類A-> B->類C,通過它我必須傳遞數字。 的父類是像這個 - import propTypes from 'prop-types'; class App extends React.Component{ constructor(props){ super(props); this.state={ t

    1熱度

    1回答

    我有一個連接遠程服務的任務。當它沒有連接時 - 啓動整個連接程序,如果已連接 - 就完成了。爲此我寫了這種方法 - public Completable execute() { return fptrService.isConnected() .flatMap(isConnected -> { if (isConnected) return Single.

    0熱度

    2回答

    我想通過反覆發射隨機數來模擬測量數據。我試着用反應堆做到這一點,但它不會產生任何輸出: private static Random random = new Random(); public static void main(String[] args) throws InterruptedException { Flux<Double> doubleGenerator = Flux

    0熱度

    1回答

    我有下面的代碼 - package com.test.rxjava; import org.reactivestreams.Subscriber; import org.reactivestreams.Subscription; import io.reactivex.Flowable; public class App1 { public static void mai