Function publishEventsWithBus

examples/todo-app/src/cli.ts:34–35

(todoId: TodoId, events: ReadonlyArray<TodoEvent>)

const publishEventsWithBus =
  (todoId: TodoId, events: ReadonlyArray<TodoEvent>) => (eventBus: Readonly<EventBusService>) =>
    pipe(events, Effect.forEach(eventBus.publish(todoId)));

const publishEvents = (todoId: TodoId, events: ReadonlyArray<TodoEvent>) =>
  pipe(EventBus, Effect.flatMap(publishEventsWithBus(todoId, events)));