Starting
import { Workflow } from '@node-ts/bus-core'
export class FulfilmentWorkflow extends Workflow<FulfilmentWorkflowState> {
configureWorkflow (
mapper: WorkflowMapper<FulfilmentWorkflowState, FulfilmentWorkflow>
): void {
mapper
.withState(FulfilmentWorkflowState)
// Start a new workflow when an `ItemPurchased` event is received
.startedBy(ItemPurchased, 'shipItem')
}
// Handles an `ItemPurchased` event
async shipItem (event: ItemPurchased) {
// ...
}
}Last updated