Описание тега rxcpp

Описание тега Вопросы с тегом
0 ответов

RxCpp: как сделать UnitTest для горячей наблюдаемой

У меня есть простой класс CFrameParser для обработки потока байтов Socket в кадры. class CDataLinkFrame { public: CDataLinkFrame(); void consumeByte(char ch); observable<std::string> getFramesObservable(); private: subjects::subject<std::st…
24 сен '18 в 09:28
1 ответ

Ошибка компиляции в реактивных расширениях для cpp

Я сталкиваюсь со странным вопросом о rxcpp, При захвате rxcpp::connectable_observable переменная и вызвать его метод подключения, я получил ошибку компиляции следующим образом. 1>------ Build started: Project: LearnRx, Configuration: Debug x64 --…
01 фев '19 в 02:39
1 ответ

Создайте заметку, от которой вы можете отписаться в RxCpp

Я портирую некоторый код из C#, который сильно зависит от Rx, и у меня возникают трудности с поиском эквивалентов C++ для некоторых из наиболее используемых методов C#. В частности, я хочу создать наблюдаемую из логики подписки / отписки. В C# я исп…
23 апр '15 в 15:11
1 ответ

Скомпилируйте rxcpp для Android

Я загружаю RxCpp из github, изменяю CMakeLists.txt следующим образом (я использую CMake, модифицированный Microsoft для создания кроссплатформенного проекта с VS2015): cmake_minimum_required (VERSION 3.4) project(RxCppAndroid VERSION 2.2.4 LANGUAGES…
31 дек '15 в 19:26
1 ответ

RXCPP, переполнение стека, когда я действительно бесконечно использовал оператор повтора в наблюдаемом

Я пытаюсь сделать заметным, что при обнаружении ошибки, это будет выполнено снова, но что-то заметил, когда "on_error()" с оператором "retry" выполняется, это только повторно запустить Observable, но, текущий экземпляр Observable все еще находится в…
02 дек '18 в 19:36
1 ответ

Как вызвать on_error для пользовательского оператора rxcpp

Я создал простой оператор rx, который преобразует поток строк в поток jsons, и он отлично работает. Тем не менее, я хотел бы иметь возможность вызывать пользовательское исключение, и я не уверен, как вызвать on_error способ подписки Оператор называе…
26 янв '17 в 15:13
1 ответ

Построить шаблон Observer/Observable с использованием RxCpp

Я пытаюсь реализовать observer/observable шаблон в Rx-cpp, Это очень интересный урок Rx.Net о том, как кто-то может к этому. В этом C# Например, есть конкретные interfaces что мы должны переопределить: public interface IObserver<in T> { void O…
12 июн '17 в 10:19
1 ответ

Как правильно вывести обобщение в пользовательском операторе rxcpp

Я создал собственный оператор rxcpp под названием validateImplementation это должно просто взять общий наблюдаемый поток, сделать некоторые проверки на SimpleInterface и либо продолжить, либо завершить поток на основе определенного условия (в моем с…
26 янв '17 в 15:35
1 ответ

RX - как использовать это быстрым способом?

Я пытаюсь понять, как структурировать мою программу, чтобы использовать RX в быстром вопросе.Мое приложение имеет вектор объектов в трехмерном мире. каждый объект занимал коробку и имел поток "попадания", который представлял над ним курсор мыши. Я п…
23 июл '17 в 00:00
1 ответ

rxcpp простой наблюдаемый<int>

Я программирую с RX на C#, и теперь я хочу программировать с RXCpp на C++. Я пытаюсь сделать самую простую вещь, определить переменную члена класса observable&lt;int&gt;,Проблема в том, что observable определяется как: template&lt;class T, class Sou…
26 фев '17 в 14:47
1 ответ

Планирование и обработка тайм-аута с помощью rxcpp

Я новичок в использовании rxcpp и пытаюсь собрать что-то функциональное вместе в следующем сценарии: У меня есть один источник данных, который будет извлекать команды из отдельного источника, код, который я пишу, будет извлекать эти команды в наблюд…
23 сен '15 в 12:00
1 ответ

Как связать две функции, возвращающие наблюдаемые?

Я написал одну функцию, которая возвращает пару QDateTime как наблюдаемый, как этот: rxcpp::observable&lt;std::tuple&lt;QDateTime, QDateTime&gt;&gt; experimentOne(const QDateTimeAxis * const axis { return rxcpp::observable&lt;&gt;::create&lt;std::tu…
16 апр '18 в 18:28
1 ответ

RxCpp: время жизни наблюдателя, если используется наблюдающая (rxcpp:: наблюдаемая_нон_руда ())

Как правильно подождать, пока все наблюдатели on_completed будут вызваны, если наблюдатели будут использовать наблюдаемую (rxcpp:: meet_on_new_thread()): Например: { Foo foo; auto generator = [&amp;](rxcpp::subscriber&lt;int&gt; s) { s.on_next(1); /…
03 сен '15 в 01:50
2 ответа

Реактивные расширения RxCpp в C++

У меня есть консольное приложение Win32, и я импортировал ссылки на Rx. Intellisense позволяет мне сделать это.... using namespace System::Reactive; using namespace System::Reactive::Concurrency; using namespace System::Reactive::Disposables; using …
28 янв '14 в 01:00
1 ответ

rxcpp: вложенный цикл while или аналогичная "классическая" императивная структура для программы

У меня есть устройство, которое передает некоторые события. Я хочу использовать реактивные расширения для моделирования следующего поведения: Определить, когда пользователь подключает ключ (моя программа проверяет наличие событий для подключенного к…
29 дек '16 в 05:46
1 ответ

Как обрабатывать поток запросов / ответов в rxcpp

Мне нужно реализовать систему выборки камеры в rxcpp. То, как я себе это представлял, это передача requestStream в качестве параметра и получение responseStream. Каждый раз, когда вызывается requestSample, создается новый сеанс камеры, а когда вызыв…
11 июл '17 в 10:56
1 ответ

rxcpp - почему не вызывается функция on_next всех наблюдателей, когда наблюдаемое выдает значение

Я пытаюсь понять, как использовать rxcpp, у меня сложилось впечатление, что, когда наблюдаемое излучает значение, все подписчики получают уведомление, вызывая свои методы on_next(), передавая им излученное значение. Это не так со следующим примером:…
18 сен '16 в 05:13
0 ответов

Реактивные расширения: Фильтруйте синхронизированные наблюдаемые

У меня есть несколько потоков (наблюдаемые RxCpp), которые основаны на одном входном потоке. Каждый поток создается путем применения операций фильтрации и сопоставления к этому входному потоку. Мраморная диаграмма примера: Input: --I0--I1--I2--I3--|…
23 дек '17 в 09:35
1 ответ

RXCPP: создайте расширение, которое не заботится о типе ввода наблюдаемой

Я хочу сделать функцию расширения, которая не заботится о типе наблюдаемого, который она получает. Например: template &lt;typename T&gt; inline auto makeones() -&gt; function&lt;observable&lt;int&gt;(observable&lt;T&gt;)&gt; { return [=](observable&…
27 июл '17 в 08:10
2 ответа

Создание пользовательских операторов в rxcpp

Я пытаюсь научиться создавать пользовательские операторы в rxcpp, и я смог создать операторы, как указано здесь. Но я хотел бы узнать, как создавать более общие операторы, реализующие rxo::operator_base и использующие оператор подъема. Есть ли докум…
10 апр '18 в 15:08