diff --git a/src/addons/hl_node_compliance.rs b/src/addons/hl_node_compliance.rs index 1ed058e52..b6d22f2de 100644 --- a/src/addons/hl_node_compliance.rs +++ b/src/addons/hl_node_compliance.rs @@ -347,8 +347,10 @@ where pubsub.log_stream(filter).filter_map(|log| adjust_log::(log, &provider)), ) .await; - } else { + } else if kind == SubscriptionKind::NewHeads { let _ = pipe_from_stream(sink, new_headers_stream::(&provider)).await; + } else { + let _ = pubsub.handle_accepted(sink, kind, params).await; } })); Ok(())