c # — Построить шаблон Observer / Observable, используя RxCpp

Question

c # — Построить шаблон Observer / Observable, используя RxCpp

Я пытаюсь реализовать observer/observable шаблон в Rx-cpp. Это очень интересно руководство в Rx.Net о том, как кто-то может к этому.

В этом C# Например, есть конкретные interfaces что мы должны переопределить:

public interface IObserver<in T>
{
void OnCompleted();
void OnError(Exception error);
void OnNext(T value);
}public interface IObservable<out T>
{
IDisposable Subscribe(IObserver<T> observer);
}

Насколько я понимаю, в Rx-cpp нет такого удобства. Итак, можно ли привести пример заголовка (myObservable.h/myObserver.h), аналогично interfaces выше, что я могу использовать в качестве руководства для определения того же шаблона коммуникации?

Любая помощь высоко ценится,
Спасибо!

РЕДАКТИРОВАТЬ 1:
Благодаря @zentrunixЯ пытаюсь сделать классно-ориентированное общение. Пока у меня есть код ниже для наблюдаемой модели. То, что я хочу, — это определить список наблюдателей, которые будут прикреплены к наблюдаемой, и когда OnNext называется эти наблюдатели должны быть уведомлены. Тем не менее, есть недостающие части.

Как я могу subscribe() на этих наблюдателей (Rx::subscribers<int>) когда myObservable::Subscribe() функции называется.
Также как я могу unsubscribe(),
Наконец, как соответствующий o.subscribe(onNext, onEnd); в нескольких onNext наблюдатели это будет? Можно ли построить соответствующий myObserver учебный класс? (снова вдохновлен Вот)

Извините за вопрос, но имеет ли смысл такая организация? До сих пор я работал с архитектурой, представленной в этом руководство и это причина, по которой я одержим этой задачей. Я нашел это как способ принять участие в RxCpp, Любые комментарии высоко ценятся.^{(Опять извините за мое невежество.)}

class myObservable {

private:

std::shared_ptr<std::list<rxcpp::subscriber<int>>> observers;

public:

myObservable() { observers = std::make_shared<std::list<Rx::subscriber<int>>>(); };

Rx::observable<int> Attach(std::shared_ptr<rxcpp::subscriber<int>> out) {

return Rx::observable<>::create<int>([&, out]() {
auto it = observers->insert(observers->end(), *out);
it->add([=]() {
observers->erase(it);
});
});

};

void OnNext(int sendItem) {

for (Rx::subscriber<int> observer : *observers) {
(observer).on_next(sendItem);
}
}

void Disposer(Rx::subscriber<int> out) {

observers->erase(std::remove(observers->begin(), observers->end(), &out), observers->end());
};
};

1

c++observer-pattern rxcpp system.reactive

Решение

Другие решения

Других решений пока нет …

Источник

Accepted Answer

Очень простой пример в RxCpp ниже.
Хотя есть (по крайней мере) одно предостережение: типичный код RxCpp интенсивно использует лямбды, которые мне очень не нравятся.

Я также пытался найти документацию и учебные пособия в Интернете, но не смог найти ни одного. Меня особенно интересуют объяснения о моделях потоков.

Если вы хотите изучить код и документацию Doxygen, на сайте RxCpp GitHub есть много примеров.

#include <iostream>
#include <exception>

#include "rxcpp/rx.hpp"namespace rx = rxcpp;

static void onNext(int n) { std::cout << "* " << n << "\n"; }
static void onEnd() { std::cout << "* end\n"; }

static void onError(std::exception_ptr ep)
{
try { std::rethrow_exception(ep); }
catch (std::exception& e) { std::cout << "* exception " << e.what() << '\n'; }
}

static void observableImpl(rx::subscriber<int> s)
{
s.on_next(1);
s.on_next(2);
s.on_completed();
}

int main()
{
auto o = rxcpp::observable<>::create<int>(observableImpl);
std::cout << "*\n";
o.subscribe(onNext, onEnd);
}

3