This is the RxJS Processor in T@skFlow. RxJS version 7 implements ReactiveX which is language-agnostic, and there are many implementations of the ReactiveX API in various programming languages, including RxJava, RxSwift, and others.
- Written in Node JS, Express, RxJS
- Fetched data is cached by SQLite
To install the node packages: npm install
Then to run: npm start
Can set the port for the websocket server with environment variable WS_PORT (defaults to 5002)
This Processor can function as a Hub Coprocessor or as a Processor depending on the NODE_NAME and associated configuration in config.mjs.
The Processor sends an update/sync request via websocket and does not update the local Task storage until it receives the update via websocket, this helps keep the Processors and Hub storages in sync.