project-reactor

1熱

1答えて

Spring 5のmongodbにユーザーを保存できませんWebFlux

Spring WebFluxと反応的なスタイルでMongoデータベースにユーザーを保存しようとしましたが、データが保存されないため、Java 8、Spring 5、mongodbがあります。 これは私の設定です： マイエンティティ： @Document public class User { @Id private String id; private String

java mongodb project-reactor spring-webflux 2017-12-08

---

0熱

1答えて

大規模なストリームを分割する際のスプリング統合バックプレッシャエラー

目標は、ローカルのダウンロードなしで、大きなjson.gzファイル（圧縮された4GB、圧縮されていない12GBの圧縮ファイル、1200万行程度）をWebサーバーからデータベースに直接流すことです。統合フローでは body = response.body().byteStream(); // thanks okhttp reader = new InputStreamReader(body, St

spring spring-integration reactive-programming project-reactor enterprise-integration 2017-12-09

---

0熱

1答えて

プロジェクトのリアクタ：エラー処理に関する誤解を招く恐れのある文書

エラー処理に関するリアクタのリファレンスドキュメントを読んでいて、何かが間違っているようです。たとえば、このセクションでは、およそfallback method： Flux.just("key1", "key2") .flatMap(k -> callExternalService(k)) .onErrorResume(e -> getFromCache(k)); しかしo

spring project-reactor 2017-12-15

---

0熱

2答えて

Reactor Schedulerは、メインスレッドが終了してから長く続いていますか？

炉3 Flux.range(1, 10000) .publishOn(Schedulers.newElastic("Y")) .doOnComplete(() -> { // WHAT should one do to ensure the worker threads are cleaned up logger.info("Shut down all Scheduler

java project-reactor 2017-12-20

---

4熱

1答えて

サブスクリプションの仕事とブロックがSpring反応Mongoにないのはなぜですか？

Kotlin,Gradle,M7およびWeb-reactiveを選択して、Spring Initializrから新しいプロジェクトを作成しました。私はデータベースに三人を保存しよう data class Person (val id: String) @Component class PersonHandler(val template: ReactiveMongoTemplate) {

mongodb spring-boot spring-data-mongodb project-reactor spring-webflux 2017-12-21

---

1熱

1答えて

リアクタマッピングモノ<Boolean>モノラル<Void>

私はMono<Boolean>を返す関数を持っています。これはMono<Void>にマップしたいと思います（これは私のコントローラメソッドで返すものです）。 .flatMap { Mono.empty<Void>() }の代わりにMonoを返す良い方法はありますか？ マッピング機能がnullを受け入れることができないため、私は.map{ null }を使用できません。

spring project-reactor 2017-12-23

---

1熱

1答えて

将来のイベントのために有限ソース上のリアクティブストリームが残っています

私は、非ブロッキングI/O（Spring Boot 2.0.0.M7）にSpring Webflux、Spring Data、およびProject Reactorを使用しています。 私の目標は、クライアントがいくつかの基準に基づいてエンドポイントからすべてのリソースを要求できるように株式ティッカーのようなAPIを作成し、最初のリクエスト後に作成される新しいリソースを受け取ることです。 Reacti

spring-data reactive-programming project-reactor spring-webflux 2017-12-27

---

0熱

1答えて

Reactor - flatMapの出力でブロックを呼び出すと、ClassCastExceptionが発生します。

私はSpring Boot 2.0.0.M7とProject Reactorを使用しています。私の問題は、単体テストの作成中に遭遇したいくつかの奇妙な動作に関連しています。私はflatMapの出力をリポジトリにフィードしようとしているときにこれにも遭遇しました。 Mono<Foo> create(Mono<FooResource> resourceMono) { resourceMono

spring-data project-reactor 2017-12-27

---

1熱

1答えて

Fluxはnull値を受け入れませんか？

Fluxのセットがあるとします。これは、二重機能と一緒に圧縮したいと考えています。オブジェクトが特定の制約を満たしている場合 Flux<String> flux1 = Flux.just("A", "B", "C"); Flux<String> flux2 = Flux.just("D", "E", "F"); Flux.zip(flux1, flux2, this::zipString).s

java spring project-reactor spring-webflux 2017-12-29

---