Использование RxJS для реализации MessageBus для связи между модулями angularjs

Question

Могу ли я создать очередь сообщений для сообщений pub/sub с помощью RxJS внутри приложения angulajs. Я имею, например, два модуля: ModuleA ModuleB Они существуют как отдельный пакет npm, но подключены в ModuleC - это основная оболочка.

Я не хочу создавать зависимость как ModuleD и создавать плотную связь между модулями. Поэтому я думал о создании шины сообщений с использованием RxJS. Возможно ли это?

Я полагаю, АНИ будет выглядеть: RxQueue.subscribe("name:of:the:queuemessage", handler => { handler.result }); RxQueue.create("name:of:the:queuemessage", (observer) => { // implementation of usual Rx subscribtion })

Answer 1

Я думаю, что это может быть ближе к тому, что вы просите:

rxmqjs/rxmq.js: JavaScript паба/суб библиотеки на основе RxJS
https://github.com/rxmqjs/rxmq.js
https://www.npmjs.com/package/rxmq

Не угловая конкретных, но Я считаю, что это хорошо.

Answer 2

Это может быть не совсем то, что вы ищете, но и для распространения состояния и данных между различными компонентами и модулями, вы можете использовать Redux/ngrx-магазин.

Redux - это архитектура, в которой вы можете отправить состояние в магазин. Магазин будет обновлять себя и уведомлять всех, кто его слушает, если что-то изменилось.

Таким образом, ваши модули могут подписаться на магазин и прослушать события. Если они хотят общаться, они могут отправить сообщение в магазин. Затем магазин будет уведомлять всех слушающих, если что-то изменилось. Единственное отличие состоит в том, что этот объект хранилища фактически сохранит этот объект в качестве базы данных temp. Это не похоже на поведение в очереди.

Оформить заказ http://redux.js.org/ для получения дополнительной информации.