( exit: Exit.Exit<A, E>, journal: Journal.Journal, scheduler: Scheduler.Scheduler, priority: number )
| 385 | |
| 386 | /** @internal */ |
| 387 | const completeTodos = <A, E>( |
| 388 | exit: Exit.Exit<A, E>, |
| 389 | journal: Journal.Journal, |
| 390 | scheduler: Scheduler.Scheduler, |
| 391 | priority: number |
| 392 | ): TryCommit.TryCommit<A, E> => { |
| 393 | const todos = Journal.collectTodos(journal) |
| 394 | if (todos.size > 0) { |
| 395 | scheduler.scheduleTask(() => Journal.execTodos(todos), priority) |
| 396 | } |
| 397 | return TryCommit.done(exit) |
| 398 | } |
| 399 | |
| 400 | /** @internal */ |
| 401 | const completeTryCommit = <A, E, R>( |
no test coverage detected