diff --git a/rpc/src/v1/impls/eth_pubsub.rs b/rpc/src/v1/impls/eth_pubsub.rs index 938562a1295..152c0a9d73b 100644 --- a/rpc/src/v1/impls/eth_pubsub.rs +++ b/rpc/src/v1/impls/eth_pubsub.rs @@ -251,8 +251,9 @@ impl EthPubSub for EthPubSubClient { kind: pubsub::Kind, params: Trailing, ) { + let error = match (kind, params.into()) { - (pubsub::Kind::NewHeads, None) => { + (pubsub::Kind::NewHeads, _) => { self.heads_subscribers.write().push(subscriber); return; }, @@ -260,9 +261,6 @@ impl EthPubSub for EthPubSubClient { self.logs_subscribers.write().push(subscriber, filter.into()); return; }, - (pubsub::Kind::NewHeads, _) => { - errors::invalid_params("newHeads", "Expected no parameters.") - }, (pubsub::Kind::Logs, _) => { errors::invalid_params("logs", "Expected a filter object.") },