reactor

    1熱

    1答えて

    デシリアライズ・エラー・春ブーツ反応

    私は例外に "Type definition error: [simple type, class reactor.core.publisher.Flux]; nested exception is com.fasterxml.jackson.databind.exc.InvalidDefinitionException: Can not construct instance of reactor
    spring spring-boot jackson reactor spring-webflux 2017-08-31

    2熱

    1答えて

    sigtermで反応炉を強制停止させる

    私は、いくつかのデータ解析を扱うGCEサーバーのセットアップをしています。私はwsでtwistedを使ってそれと通信することができます。私はこのサーバーの唯一のクライアントです。それはクライアントの接続を処理しているので、 spawn_multiprocessing_hierarchy() reactor.run() # Blocks main thread stop_everything_a
    python twisted reactor twisted.internet sigterm 2016-11-11

    1熱

    1答えて

    node.js/libuvはリアクタパターンを使用してasync ioをどのようにサポートしますか

    IOを処理するためにlibuvで使用されるリアクタパターンは設計上同期していますが、libuvはasync ioをサポートしています。これはどのように可能ですか？ libuvは原子炉の設計を何とか非同期ioをサポートするように拡張していますか？これを達成するには、複数のスレッド/イベントループを使用するのが助かりますか？
    node.js asynchronous io libuv reactor 2017-07-20

    1熱

    1答えて

    テストスプリング5リアクティブレストサービス

    私はSpringBoot 2とSpring 5（RC1）を使ってリアクティブなRESTサービスを公開しています。私はそれらのコントローラの単体テストを書くことはできません。ここで 私は本当のものを呼び出すためにないたいと思いますので、私のコントローラ @Api @RestController @RequestMapping("/") public class MyController {
    spring rest spring-boot reactor 2017-06-13

    1熱

    1答えて

    リアクターの使用doOnNext複数回

    少しの反応器サンプルをhereから変更しようとしていましたが、私は少し行動が混乱しています。 したがって、このような最初のIコード： EmitterProcessor<String> stream = EmitterProcessor.<String>create().connect(); Flux<String> flux = stream .doOnNext(s ->
    reactor 2016-11-28

    0熱

    1答えて

    オートバン+ツイストの再接続

    私はクライアントに、wsプロトコルで常にサーバーに接続する必要があります。さまざまな理由から、接続が時々落ちます。これは受け入れられますが、それが起こったときに私のクライアントが再接続したいと思います。 現在のところ、私の一時的な回避策は、親プロセスにクライアントを起動させ、接続が切断されたことを検出した時点で終了します（クライアントは重要なデータを処理しません。sigkillを実行しても問題あり
    tcp autobahn reactor reconnect twisted.internet 2017-01-19

    0熱

    1答えて

    Reative SpringのCakeBaseリポジトリのdeleteAllを呼び出すとClassCastExceptionがスローされました

    私はちょうどリアクティブフィーチャーをSpring Data Couchbaseで提供しようとしました。 アプリケーションのデータを初期化するために、DataInitializerクラスがあります。 @Component @Slf4j class DataInitializer { private final PostRepository posts; public D
    spring rx-java reactor spring-data-couchbase spring-webflux 2017-09-29

    0熱

    1答えて

    春5原子炉 - 発光項目ごとに1秒

    私は Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1)) として毎秒値を放出しようとしていますが、それは1秒の遅延を開始すると、一度にすべてを放出しています。どのように各要素の放射を遅延させることができますか？
    spring kotlin rx-java reactor 2017-10-04

    0熱

    1答えて

    春が自動的にここResponseEntity

    で、残りのコントローラの応答をラップすることは、私が達成しようとしているものです： 私はこれらのすべての応答をラップしたいと思い、このようなモノ、フラックス など、さまざまなオブジェクトを返す多くの春の残り反応コントローラを持っていますResponseEntityなどは常に次のようになります。 Mono<ResponseEntity<MyObjects>> いずれかの提案がありますか？あなたが
    spring spring-rest reactor 2017-06-30

    -6熱

    2答えて

    .NETでオブザーバパターンを実装するクラスの名前？

    observerパブリッシュサブスクライブパターンを実装する.NETライブラリのクラスの名前は何ですか？ はreactor patternで実装されており、observer and reactor patternには違いがあることを理解しています。答えを選択した後 更新： は、この質問は閉じるように3票を受け取りました。この質問に答えがないので、その理由がわからない。ここで私が答えで知っているのは
    c# .net observer-pattern reactor 2017-03-27
最新の質問