(enqueuingBlocks: (IBlock<FB> | number)[], latestHeight: number)
| 322 | } |
| 323 | |
| 324 | private async enqueueBlocks(enqueuingBlocks: (IBlock<FB> | number)[], latestHeight: number): Promise<void> { |
| 325 | const cleanedBatchBlocks = filterBypassBlocks<FB>(enqueuingBlocks, [ |
| 326 | ...this.projectService.bypassBlocks, |
| 327 | ...this.getDatasourceBypassBlocks(), |
| 328 | ]); |
| 329 | await this.blockDispatcher.enqueueBlocks( |
| 330 | cleanedBatchBlocks, |
| 331 | this.getLatestBufferHeight(enqueuingBlocks, latestHeight) |
| 332 | ); |
| 333 | } |
| 334 | |
| 335 | /** |
| 336 | * |
no test coverage detected