reactive

0熱

1答えて

フィールドが変更されたときにクラスに反応フィールドを作成することはできますか？私は私は私のグローバルオブジェクトの「add_catalogを（）」を使用する場合、いくつかの光沢のあるウィジェットを更新したいと思います CatalogModele <- setRefClass("CatalogModele", fields = list(catalogs = "list"), m

1熱

2答えて

希望のスレッド/タスクをブロックせずに最初のIObservableイベントを取得

IObservableを使用して、AC＃asyncメソッド内の要求応答環境で応答を取得し、古いコールバックベースのコードを置き換えてみましたが、観測値に値が（Subject.OnNext）プッシュされているのに、まだFirstAsyncが待たれていない場合は、FirstAsyncにそのメッセージは決して与えられません。 2番目のタスク/スレッドと同期の両方がなくても、動作させる簡単な方法はあります

1熱

1答えて

Shiny：「すべての行」オプションを含む動的プルダウンメニューを作成する

テーブルのすべての行を表示するShinyアプリケーションを作成しようとしているか、ユーザーが行のサブセットを選択できるようにしています。最終的に複数のプルダウンメニューが表示されますが、今は1つの作業をすべて終わらせようとしています。何らかの理由で、filter（）ステートメントのStatusがアプリによって見つかりません。これはおそらく、プルダウンメニューで何も選択されていない場合にすべての行

1熱

3答えて

Shinyの反応性オブジェクトの操作 - < - ：無効な（NULL）の割り当ての左端

エラー：「<のエラー：無効な（NULL）の割り当ての左側」が繰り返し表示されます。光沢のある反応性のある物体を取り出し、それをさらに操作しようとする。私は以下に例証的な例を示しました。私は私の実際のコードで行う必要がありますどのような testdf <- data.frame(row1 = c(1,3,6), row2 = c(7, 5, 1)) ui <- fluidPage( t

0熱

1答えて

Android RxJava2ハンドルオリエンテーションが変更されました

私はこのライブラリでは新しいので、ヒントやご提案があれば歓迎する以上です。は、私が実行しているとlongNetworkOperation偽の方法を実行RxJava2を得た、流れはこれです：観測可能作成します。Observable.just（ "STR1"）変更の実行スレッド：.subscribeOn（Schedulers.newThreadを（）） LongRunningProcessを実

1熱

1答えて

Shinyは、ループを使用して入力から反応変数を割り当てます。

ループを使用して入力に基づいて反応変数を割り当てようとしています。たとえば、虹彩データセットの列（入力から）を選択したいとします。次に、その列から一意の値を取得します。そして私はこれをループでやりたい私はそれが私の 'ジョーク'変数のために働くが、私のグループ[[paste0（ 'Gcol'、i）]]変数のためではないことがわかる。私は数日間この答えを探してきました。ご協力いただきありがとうござ

2熱

1答えて

Reactive KafkaをConfluent Schema Registryと連携させるAvroスキーマ

Reactive Kafka（https://github.com/akka/reactive-kafka）をConfluent Schema Registry Avroスキーマと連携させるには？ここに私のサンプルコードは次のとおりです。 def create(groupId: String)(implicit system: ActorSystem): Source[ConsumerMessag

0熱

1答えて

同期の観測は、私は以下のようにサービスを削除ODATA呼び出すdeleteメソッドを持って

呼び出します。データグリッドの場合、3行を削除すると、メソッドは個々の行に対して3回呼び出されます。メソッドdeleteValuesが次々に3回呼び出されても、1と2のサービスコールは、1のサービスコールが完了したときにのみ行われる必要があります。

5熱

1答えて

Spring Reactive WebClient

私は、他のレストサービスからのデータを要求するために、スプリングWebClientクラスを使用する反応性の残りのAPI（webflux）を持っています。簡体デザイン：つまり @PostMapping(value = "/document") public Mono<Document> save(@RequestBody Mono<Document> document){ //1st Pro