Merge pull request #129 from s7techlab/separate-observer-parsing-v2

separate-observer-parsing-v2
s7techlab · Oct 3, 2023 · aa789df · aa789df
2 parents bd5ca79 + 639f088
commit aa789df
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/observer/block_channel_parse.go b/observer/block_channel_parse.go
@@ -68,6 +68,8 @@ func (p *ParsedBlockChannel) Observe(ctx context.Context) (<-chan *ParsedBlock,
 		return nil, fmt.Errorf("observe common blocks: %w", err)
 	}
 
+	p.blocks = make(chan *ParsedBlock)
+
 	go func() {
 		p.isWork = true
 

diff --git a/observer/block_peer_parse.go b/observer/block_peer_parse.go
@@ -49,7 +49,10 @@ func WithConfigBlocks(configBlocks map[string]*common.Block) ParsedBlockPeerOpt
 
 func NewParsedBlockPeer(blocksPeer *BlockPeer, opts ...ParsedBlockPeerOpt) *ParsedBlockPeer {
 	parsedBlockPeer := &ParsedBlockPeer{
-		blockPeer: blocksPeer,
+		blockPeer:              blocksPeer,
+		parsedChannelObservers: make(map[string]*parsedBlockPeerChannel),
+		blocks:                 make(chan *ParsedBlock),
+		blocksByChannels:       make(map[string]chan *ParsedBlock),
 	}
 
 	for _, opt := range opts {