Understand MountPoint
A 'mountpoint' is an object able to communicate by using RxJS Subject one for 'tasks' and other for 'reply'. Using Subject's subscribe and next method to can send and receive messages from other obejcts.
First create a component/s see the quick start for example. On the most simple case you just communicate with the component by:
Of course you can create sevral components communicate with them regardless of any job execution. Use the TxMountPointRegitry to retreive the component's mountpoint.
mountpoint.tasks().next(new TxTask(head, data)) - sending taks to a component.
Use the TxMountPointRegitry to retreive the component's mountpoint.
mountpoint.reply().next(new TxTask(head, data)) - sending reply to a component usually the one that send the tasks.
Use the TxMountPointRegitry to retreive the component's mountpoint.
mountpoint.tasks().subscribe((data) => {..}) - to receive tasks from anyone
Use the TxMountPointRegitry to retreive the component's mountpoint.
mountpoint.reply().subscribe((data) => {..}) - to receive reply from onyone.
Last updated