問題タブ [event-stream-processing]
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.
haskell - haskell でのイベント ストリームの処理
MQTT 経由で受信したイベントのストリームを処理したい。私が使用しているライブラリは、コールバックを使用して結果を提供します。私が行っている処理は、最新のイベントだけでなく、以前の状態に依存します。また、将来的には、他のソースからイベントが収集される可能性があります。
最初に、良いアイデアだと思われるリストに構成することにしました。IOが遅延評価を妨げ、無限ストリームの待機が長くなる可能性があるという小さな問題がありましたが、IOをインターリーブすることで解決しました。
stream :: IO [Event]foldl、foldM map、などのような素晴らしいことを行うことができますmapM... 残念ながら、このアプローチでは、ロック機能がもうないため、2 つのストリームを結合することはできません。
私は多くのライブラリを掘り下げていて、たとえば TQueue を使用した STM を見つけました。残念ながら、それは私が正確に望んでいるものではありません。
カスタムタイプを作成してFoldable、折りたためるようにすることにしました。IOが原因で失敗しました。
次のように使用できますmain = foldStream (\x _ -> print x) () =<< events
通常のリストと同様に、このストリームで動作する基本クラスのいくつかを実装することは可能ですか?