Move the responsibility of waiting between block fetch to the block f…

…etcher ... It will be easier to throttle the block flow from the fetcher since rate limit and API restriction will vary depending on the chain and service provider ...

blockpoller/fetcher.go

@@ -2,12 +2,10 @@ package blockpoller
 
 import (
 	"context"
-	"time"
 
 	pbbstream "github.com/streamingfast/bstream/pb/sf/bstream/v1"
 )
 
 type BlockFetcher interface {
-	PollingInterval() time.Duration
 	Fetch(ctx context.Context, blkNum uint64) (*pbbstream.Block, error)
 }

blockpoller/poller.go

@@ -3,7 +3,6 @@ package blockpoller
 import (
 	"context"
 	"fmt"
-	"time"
 
 	"github.com/streamingfast/bstream"
 	"github.com/streamingfast/bstream/forkable"
@@ -85,7 +84,6 @@ func (p *BlockPoller) run(resolvedStartBlock bstream.BlockRef) (err error) {
 
 	currentCursor := &cursor{state: ContinuousSegState, logger: p.logger}
 	blkIter := resolvedStartBlock.Num()
-	intervalDuration := p.blockFetcher.PollingInterval()
 	for {
 		if p.IsTerminating() {
 			p.logger.Info("block poller is terminating")
@@ -99,8 +97,6 @@ func (p *BlockPoller) run(resolvedStartBlock bstream.BlockRef) (err error) {
 		if p.IsTerminating() {
 			p.logger.Info("block poller is terminating")
 		}
-
-		time.Sleep(intervalDuration)
 	}
 }