separate-observer-parsing-v2

s7techlab · Oct 4, 2023 · cb17bbc · cb17bbc
1 parent aa789df
commit cb17bbc
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/observer/block_peer_concurrently_parse.go b/observer/block_peer_concurrently_parse.go
@@ -24,6 +24,9 @@ func (pbp *ParsedBlockPeer) ObserveByChannels(ctx context.Context) (*ParsedBlock
 	pbp.mu.Lock()
 	defer pbp.mu.Unlock()
 
+	// need to start default block peer observing
+	_, _ = pbp.blockPeer.ObserveByChannels(ctx)
+
 	blocksByChannels := &ParsedBlocksByChannels{
 		channels: make(chan *ChannelParsedBlocks),
 	}

diff --git a/observer/block_peer_parse.go b/observer/block_peer_parse.go
@@ -67,6 +67,9 @@ func (pbp *ParsedBlockPeer) Observe(ctx context.Context) (<-chan *ParsedBlock, e
 		return pbp.blocks, nil
 	}
 
+	// need to start default block peer observing
+	_, _ = pbp.blockPeer.Observe(ctx)
+
 	// ctxObserve using for nested control process without stopped primary context
 	ctxObserve, cancel := context.WithCancel(ctx)
 	pbp.cancelObserve = cancel