diff --git a/pkg/morph/subscriber/subscriber.go b/pkg/morph/subscriber/subscriber.go
index 73ad5a7f..39c65107 100644
--- a/pkg/morph/subscriber/subscriber.go
+++ b/pkg/morph/subscriber/subscriber.go
@@ -104,10 +104,6 @@ func (s *subscriber) Close() {
 }
 
 func (s *subscriber) BlockNotifications() (<-chan *block.Block, error) {
-	if err := s.client.Init(); err != nil {
-		return nil, errors.Wrap(err, "could not init ws client")
-	}
-
 	if _, err := s.client.SubscribeForNewBlocks(nil); err != nil {
 		return nil, errors.Wrap(err, "could not subscribe for new block events")
 	}
@@ -171,6 +167,10 @@ func New(ctx context.Context, p *Params) (Subscriber, error) {
 		return nil, err
 	}
 
+	if err := wsClient.Init(); err != nil {
+		return nil, errors.Wrap(err, "could not init ws client")
+	}
+
 	sub := &subscriber{
 		RWMutex:   new(sync.RWMutex),
 		log:       p.Log,