rxcpp

0熱

1答えて

validateImplementationというカスタムrxcpp演算子を作成しました。これは一般的な観測可能なストリームを取得し、SimpleInterfaceでいくつかのバリデーションを行い、特定の条件 https://github.com/cipriancaba/rxcpp-examples/blob/master/src/SimpleOperators.cpp template <cla

1熱

1答えて

RxCPPはRx.Netと異なる動作をします

私はRxCPPを使用しており、その動作を理解するのが難しいです。ここにはRx.NetとRxCPPの2つのプログラムがあります。同じ印刷物を出力すると思われますが、同じ印刷物は出力しません。プログラムはマウスストリームからポイントを取得し、ポイント間のデルタのストリームを計算します。マウスはポイントのストリームのストリームであり、すべてのストローク - から上から上へ押すことは1ストリームで

7熱

1答えて

llvmエラー：再配置はまだ実装されていません！ orcjitまたはlliでRxCppを実行しているとき

llvmのIRインタープリタlliでRxCppの例を実行したいと思います。残念ながら、RxCppの例のいずれかを実行すると、LLIに失敗します。 git clone https://github.com/Reactive-Extensions/RxCpp.git --depth 1 cd RxCpp/Rx/v2/examples/pythogerian clang++ -S -emit-ll

2熱

1答えて

rxcpp

に要求/応答ストリームを処理する方法を私はrxcppにカメラサンプリングシステムを実装する必要があります..私は、これはのparamとしてrequestStreamを渡すとresponseStream たびrequestSampleが呼び出されるを受信している想像方法、新しいカメラのセッションが作成され、on_completeは（）requestStreamのために呼び出されたときに、カメラセ

2熱

1答えて

RXCPP：ブロック機能のタイムアウト

ブロック機能を検討してください。this_thread :: sleep_for（milliseconds（3000））; 私は、次の動作を取得しようとしている： Trigger Blocking Function |---------------------------------------------X 私はブロッキング機能をトリガーにしたいし、それが（2秒以上）長すぎるがかか

3熱

1答えて

rxcpp - なぜオブザーバブルが値を出すときに、オブザーバのon_next関数が呼び出されないのですか？

私はrxcppの使い方を理解しようとしています。 on_next（）メソッドが呼び出されることによって通知され、放出された値が渡されます。 auto eventloop = rxcpp::observe_on_event_loop(); printf("Start task\n"); auto values = rxcpp::observable<>::interval(std::chro

1熱

1答えて

ラムダ関数に渡されたヌルポインタがnullになっていません

ラムダ関数への参照としてヌルポインタを渡そうとしますが、nullのままではなくメモリアドレスを受け取ります。 function<void(json)> doTheThing(){ ... pointer = nullptr; return [&](json object) { if(pointer != nullptr) { cout<<"poi

1熱

1答えて

RXCPP：オブザーバブルの入力タイプを気にしない拡張機能を作成する

受け取ったオブザーバブルの種類を気にしない拡張機能を作りたいと思っています。例えば： template <typename T> inline auto makeones() -> function<observable<int>(observable<T>)> { return [=](observable<T> s) { return s | rxo::map([=](aut

1熱

1答えて

RxCppを使用してObserver/Observableパターンを構築する

Rx-cppにobserver/observableパターンを実装しようとしています。これらは、誰かがこれにどのように対処できるかについて、非常に興味深いtutorialであるRx.Netです。このC#例で、我々はオーバーライドする必要があり、そのinterfaces特定があります。 public interface IObserver<in T> { void OnComplete