fix: Override NewHeads only

This commit is contained in:
sprites0
2025-10-13 02:57:05 +00:00
parent 51924e9671
commit 6c3ed63c3c

View File

@ -347,8 +347,10 @@ where
pubsub.log_stream(filter).filter_map(|log| adjust_log::<Eth>(log, &provider)),
)
.await;
} else {
} else if kind == SubscriptionKind::NewHeads {
let _ = pipe_from_stream(sink, new_headers_stream::<Eth>(&provider)).await;
} else {
let _ = pubsub.handle_accepted(sink, kind, params).await;
}
}));
Ok(())