reactive

0熱

2答えて

私はRx（特にRxSwift）を学んでおり、アーキテクチャ、レイヤー、境界について質問があります。私は通常、MVPまたはVIPER上の階層化されたアーキテクチャ（データ、ドメイン、プレゼンテーション）に慣れています。このプロジェクトでは、Reactiveアプリケーションの推奨アーキテクチャであるMVVMを使用しています。これらは、私の現在の協力者です： **** Presentation ***

1熱

1答えて

私はspring-boot-startter-data-mongodb-reactiveとspring-boot-starter-webfluxの依存関係を確認していません。

私はリンクからSpring Reactiveの例に従っています：https://github.com/mohitsinha/tutorials/blob/master/spring-boot-webflux-reactive-mongo/build.gradle。私はMavenを使って開発している同じプロジェクトですが、以下のMaven依存関係は表示されません。私は何を使うべきですか？ compi

0熱

1答えて

光沢のあるRMarkdownの要素を隠す

光沢のあるrmarkdownの要素をユーザーから隠しても、反応性の値を得ることができました。 Picture 1 参照ハロー：1、renderTextは、入力$クラスタからの反応値を取得することを、示してどのような私が得たもの --- title: "My Title" author: "My Name" date: "Today" output: rmdformats::htm

1熱

1答えて

withMathJaxフォーマットは

サンプルコードを変更：は当初、アプリが正常に動作します： ui <- fluidPage( withMathJax(), tags$div(HTML("<script type='text/x-mathjax-config'> MathJax.Hub.Config({ tex2jax: {inlineMath: [['$','$'], ['\\

1熱

1答えて

vertex.x ReactiveReadStreamを<Document>からReactiveWriteStreamに変換するには<Buffer>

私は単純な使用例があります。これは、レスポンスストリーム型のバックプレッシャー管理を使用して、残りの呼び出しを行い、mongoをクエリしてから、任意に大きなデータストリームをクライアントに返すことです。これは、Spring WebFluxとReactorを使用して簡単に達成できました。私は現在、実装の容易さの比較として、vert.xを使用して同じ目標を達成しようとしています。 vertex.xm

0熱

1答えて

何回も何回も放射するのですか？

ソースオブザーバブルとしてngrxを使用する次のコードを試しました。 this.continue$ = this.store.select(s => s.cart) .switchMap(cart => Observable.from(cart.items)) .every(item => item.amount > 0 && item.amount <= item.max_a

1熱

1答えて

RxJSはすべてのイベントを受け取るわけではありません

私はRxJSに関する練習をしています。そして、何かが非常に奇妙な出来事があります： typoStream.subscribe(x => console.log('wont get executed')); wordCompletedStream.subscribe(nextStream); typoStream.subscribe(x => console.log('will

0熱

1答えて

R shiny：reactiveValuesを使用して反応性データフレームを変換して観察する

reactiveValuesを使用して反応性data.frameを変換して観察するのに問題があります。私はregular reactive（）を使う方が慣れており、reactiveValuesをあまり把握できません。私は、 "バイオマス"という列をtmp3というdata.frameに追加したいと思います。私はtmp2を変換し、 "クラス"と "共通"と呼ばれる列を問題なく追加することができます。サ

0熱

1答えて

RxJs：Observableはステートフルですか？

私はコードの下にしようとしたので、私はこれを聞いてるのよ： //RxJs v5.5.2; NodeJs v7.10.1 var Rx = require('rxjs/Rx'); var observable = Rx.Observable.of(1,2,3); var sub = observable.subscribe(console.log); var sub1 = observab

1熱

1答えて

Webflux mongo複数のモデルを保存

私のアプリケーションでは、サーバーとユーザーがあり、各ユーザーは複数のサーバーを持つことができます。 User内のサーバーのリストです@DBref：私はその後、私は、ユーザーのサーバーリストにサーバーを追加し、ユーザーを保存し、私が最初に作成し、サーバーを保存し、サーバーを作成したいコントローラで @DBRef private List<Server> servers; ： @PostMap