(epoch: number, batch: number, logs: UnresolvedLogs)
| 401 | } |
| 402 | |
| 403 | async maybeWait(epoch: number, batch: number, logs: UnresolvedLogs) { |
| 404 | const ps: Array<void|Promise<void>> = []; |
| 405 | if (this.yield != null) { |
| 406 | await resolveScalarsInLogs(logs); |
| 407 | ps.push(this.yield(epoch, batch, logs as Logs)); |
| 408 | } |
| 409 | ps.push(this.nextFrameFunc()); |
| 410 | await Promise.all(ps); |
| 411 | } |
| 412 | |
| 413 | override async onEpochBegin(epoch: number, logs?: UnresolvedLogs): |
| 414 | Promise<void> { |
no test coverage detected