diff --git a/pkg/listener/listener.go b/pkg/listener/listener.go
index a32f0be..33797cd 100644
--- a/pkg/listener/listener.go
+++ b/pkg/listener/listener.go
@@ -252,6 +252,7 @@ func (l *Listener) subscribeNewBlockHead(ctx context.Context, blockCh chan<- typ
 		case <-ticker.C:
 			if time.Since(lastReceivedTime) > l.sanityCheckInterval {
 				l.l.Errorw("Websocket connection is corrupted", "lastReceivedTime", lastReceivedTime)
+
 				return errConnectionCorrupted
 			}
 		case header := <-headerCh: