project-reactor

8熱

2答えて

ReactiveStreamsの近くにある自家製ログ処理ライブラリをio.projectreactorに置き換えることを検討しています。目的は、私たちが維持しているコードを減らし、コミュニティーが追加した新しい機能を利用することです（オペレーター融合を目指す）。まず、stdioを消費して、複数行のログエントリをパイプラインを流れるテキストのBLOBにマージする必要があります。ユースケースについて

2熱

1答えて

HTTP統合フローからSpring Reactor Fluxを作成するにはどうすればいいですか？

私はメッセージがHTTPエンドポイントではなく、JMSキューから来る1つの違いで、この1 How to create a Spring Reactor Flux from a ActiveMQ queue? に非常に似て質問があります。問題は、Message Channelが何らかの理由で実装されていないか、Flux.from（）によって取得されていないことです。ログエントリはGenericMes

0熱

1答えて

Reactor/RxJava SQSから読むときのバックプレッシャー

私はリアクションパラダイム全体に慣れていないし、SQSのような待ち行列から読むときの背圧の働きを理解しようとしている。反応器内のあなたのフラックスを持っているだろうし、RxJavaにあなたのような背景の中で、あなたの観察可能なポーリングSQSを持っていると思います： while (true) { Future<ReceiveMessageResult> future = sqsClie

1熱

1答えて

は、モノラルにフラックスを変換するモノでメソッドを実行し、私はこの機能を実装する必要が

を束に戻って変換： // TODO Capitalize the users username, firstName and lastName // using #asyncCapitalizeUser method below Flux<User> asyncCapitalizeMany(Flux<User> flux) { } Mono<User> asyncCapitalize

1熱

1答えて

スプリングブートv2.0.0.M2 webfluxとアクチュエータ

ActuatorをSpring Boot v2.0.0.M2とNettyで動作させることができません。次の依存関係はbuild.gradleで使用されています compile "org.springframework.boot:spring-boot-starter-actuator" compile "org.springframework.boot:spring-boot-start

1熱

1答えて

現在実行中のスレッドが待機状態になったときに、runOn（）メソッドがプールから次に使用可能なスレッドでmap演算子を実行しないのはなぜですか？

4コアマシンで次のコードを実行しようとしています。プールに5つのスレッドがあり、マップ演算子では、実行スレッドを数秒間スリープ状態にします。コアが実行中のスレッドをスリープ状態にし、次のイベントが利用可能になると、スレッドプールから次の使用可能なスレッドでマップ操作を実行する必要がありますが、私が見る動作ではありません。プールからの4つのスレッドが13秒間待機し、待機が完了した後でのみ次のイベ

0熱

1答えて

Reactorに基づくSpring MVCとは何ですか？

私はSpringとReactorに関するすべてのことを読んでおり、今後のSpring Framework 5にはReactorが含まれることになっていることを理解していますか？興味がありますSpring MVCは、現在のところフレームワークの一部ではないため、ReactorをSpring MVCでどのように使用できますか？ Framework 5を待っている間にReactorをSpringで使用

0熱

1答えて

長い実行タスクを持つモノをマップの中に戻すにはどうすればいいですか？

私はモノのマップ機能内のデータを変換したい： long result = 0.0; return Mono.just(result).map(value -> { // do some long running transformation here // and assign it to result (maybe 5 seconds task) // in o

0熱

1答えて

forループの代わりにFluxを使用すると、どんな利点がありますか？

私はここにフラックスを使用するいずれかの利点がある場合、私はお願いしたいと思いますので、反応性プログラミングのまわりで私の頭を取得しようとしています： override fun notifyObserversOnMessage(message: Message) { Flux.fromStream(observers.stream()) .map { observer

0熱

1答えて

RxJava 1.1.5をReactor Core 3.1.0.M3に変更する

RxJava 1.1.5をSpring WebFlux（Reactor Core 3.1.0.M3）で使用するライブラリを使用しようとしていますが、ObservableをFlux。私は、これは比較的簡単だろうと思ったが、私のアダプタが機能していません。 import reactor.core.publisher.Flux; import rx.Observable; import rx.Su