問題タブ [reactive-streams]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Cyclops-react と async-retry: タイムアウト時に再試行するには?
私はサイクロプス反応を非同期再試行で使い始めています。私はまだそれで少し迷っています。
SimpleReact を使用してサーバーからのタイムアウトをシミュレートしていますが、次のようなタイムアウトを受け取ることはありません。
そこに欠けているものは何ですか？
akka - Akka Streams: What does Mat represents in Source[out, Mat]
In Akka streams what does Mat in Source[Out, Mat] or Sink[In, Mat] represent. When will it actually be used?
scala - データベースへのリアクティブ API の提供
ストリーミングをサポートしていないデータベースに反応ストリーム API を提供するにはどうすればよいですか? たとえばdynamodbとしましょう。get 呼び出しを実行すると、dynamodb はすべての結果を返します。ソースで get 呼び出しをラップしたとしても、ダウンストリーム ステージからのバックプレッシャーをどのように処理すればよいでしょうか? また、書き込み呼び出しを db に実装するにはどうすればよいですか? 私のシンクはどのように見えますか？これに関する指針は役に立ちます。
scala - Akka Streams はストリームをタイプ別に分割します
次の単純なケース クラス階層があります。
そして、私はFlow[Message, Message, NotUsed]（コーデックが既に配置されているWebsocketベースのプロトコルから）を持っています。
Flow[Message]Foo 型と Baz 型は完全に異なる経路で処理されるため、これを別のフローに分離したいと考えています。
それを行う最も簡単な方法は何ですか？明らかなはずですが、何かが欠けています...
transactions - Akka ストリームとトランザクション境界
私はまだ Akka ストリームの概念を把握しており、アトミックな方法で処理する必要があるアイテムのコレクションがある場合に、それらをシナリオにマッピングする方法を理解しようとしています。複数のアイテムで構成される注文書があり、各アイテムに何らかの処理を適用してから、単一の値にマージする必要があるとします。そのようなワークフローは、発注書が完全に処理されると閉じられる独自の別個のストリーム (またはサブストリーム) になる必要がありますか? つまり、各注文書は新しいストリームを開始しますか? それとも、終わりのない一連の注文書がありますか? しかし、そうであれば、異なる注文からの購入注文が混在するという問題はありませんか?
言い換えれば、私が達成しようとしているのは、さまざまなワークフローの分離を処理することであり、Akka ストリームがそれに適しているかどうか疑問に思っています。
rx-java - RxJava 2.0 で Reactive-Streams プロセッサを使用する
org.reactivestreams.ProcessorRxJava 2.0 で使用したい があります。ただし、org.reactivestreams.Publisherを RxJavaと統合するための変換はありますが(または)io.reactivex.Flowable#fromPublisherを最適に統合する方法は明確ではありません。誰でもこれに光を当てることができますか？org.reactivestreams.Processororg.reactivestreams.Subscriber
scala - Kafka tests failing intermittently if not starting/stopping kafka each time
I'm trying to run some integration tests for a data stream using an embedded kafka cluster. When executing all the tests in a different environment than my local, the tests are failing due to some internal state that's not removed properly.
I can get the all the tests running on the non-local environment when I start/stop the kafka cluster before/after each test but I only want to start and stop the cluster once, at the beginning and at the end of the execution of my suite of tests.
I tried to remove the local streams state but that didn't seem to work:
Is there a way to get my suit of tests running without having to start/stop cluster each time?
Right below there are the relevant classes.
Any help over this would be much appreciated? Thanks in advance.
java - RxJava 2.0 - Observable を Publisher に変換する方法
RxJavaバージョン2でObservableをPublisherに変換するには?
最初のバージョンには、まさに必要なことを行うhttps://github.com/ReactiveX/RxJavaReactiveStreamsプロジェクトがあります。しかし、どうすればRxJava 2でそれを行うことができますか?