diff --git a/db/test_helper.go b/db/test_helper.go index 9e6a2637..2779a583 100644 --- a/db/test_helper.go +++ b/db/test_helper.go @@ -17,3 +17,12 @@ func ConnectBlocks(w *SyncWorker, onNewBlock bchain.OnNewBlockFunc, initialSync func HandleFork(w *SyncWorker, localBestHeight uint32, localBestHash string, onNewBlock bchain.OnNewBlockFunc, initialSync bool) error { return w.handleFork(localBestHeight, localBestHash, onNewBlock, initialSync) } + +// ConnectBlocksParallel keeps legacy integration tests compiling against the new API. +func (w *SyncWorker) ConnectBlocksParallel(lower, higher uint32) error { + workers := w.syncWorkers + if workers < 1 { + workers = 1 + } + return w.ParallelConnectBlocks(nil, lower, higher, uint32(workers)) +}