fun wasRequested(connectionId: String, header: BlockHeader): CompletableAsyncCompletion?
fun wasRequested(connectionId: String, bodies: List<BlockBody>): Request?