We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 4afed9e + c37b1f4 commit fcde75dCopy full SHA for fcde75d
1 file changed
clients/consensus/rpc/beaconstream.go
@@ -76,9 +76,10 @@ func (bs *BeaconStream) startStream() {
76
// Subscribe to basic events (block, head, finalized_checkpoint)
77
basicEvents := bs.events & (StreamBlockEvent | StreamHeadEvent | StreamFinalizedEvent)
78
basicStream := bs.subscribeStream(bs.client.endpoint, basicEvents)
79
- if basicStream != nil {
80
- defer basicStream.Close()
+ if basicStream == nil {
+ return
81
}
82
+ defer basicStream.Close()
83
84
// Subscribe to advanced events (execution_payload_available, execution_payload_bid)
85
// These are in a separate stream because clients may not support them yet,
0 commit comments