@aegenet/belt-task-flow

> Enables loosely coupled publish/subscribe messaging. Awaiting version with FIFO (first in first out)

💾 Installation

``shell
yarn add @aegenet/belt-task-flow@^2.0.0


or


npm i @aegenet/belt-task-flow@^2.0.0
`

📝 Usage

$3

`typescript
import { TaskFlow, type ITaskFlow } from '@aegenet/belt-task-flow';

const taskFlow: ITaskFlow = new TaskFlow();

const tabs: string[] = [];

taskFlow.subscribe('Something', async () => {
await delay(200);
tabs.push('with delay');
});

taskFlow!.subscribe('Something', () => {
tabs.push('without delay');
});


await taskFlow!.publish('Something');

// tabs => ['with delay', 'without delay']

await taskFlow!.publish('Something');

// tabs => ['with delay', 'without delay', 'with delay', 'without delay']

taskFlow.dispose();
`

$3

Note: Stage 3 decorator (for stage 2, you can use an older version (< 2.0.0) of this package).

`typescript
import { TaskFlow, type ITaskFlow, TaskFlowListener, taskFlowMethod } from '@aegenet/belt-task-flow';

const taskFlow: ITaskFlow = new TaskFlow();

class ListenToMe extends TaskFlowListener {
public msg: string[] = [];

constructor() {
super(taskFlow!);
}

@taskFlowMethod()
public doIt() {
this.msg.push('hello');
}
}

// [...]
const listenToMe = new ListenToMe();

// publish
await taskFlow!.publish('tf.ListenToMe:doIt');
// listenToMe.msg => ['hello']

// [...]
listenToMe.dispose();
taskFlow.dispose();
``