diff --git a/validator/src/bin/solana-test-validator.rs b/validator/src/bin/solana-test-validator.rs index 487729f77d..34565cba7e 100644 --- a/validator/src/bin/solana-test-validator.rs +++ b/validator/src/bin/solana-test-validator.rs @@ -154,6 +154,7 @@ fn main() { let rpc_port = value_t_or_exit!(matches, "rpc_port", u16); let enable_vote_subscription = matches.is_present("rpc_pubsub_enable_vote_subscription"); + let enable_block_subscription = matches.is_present("rpc_pubsub_enable_block_subscription"); let faucet_port = value_t_or_exit!(matches, "faucet_port", u16); let ticks_per_slot = value_t!(matches, "ticks_per_slot", u64).ok(); let slots_per_epoch = value_t!(matches, "slots_per_epoch", Slot).ok(); @@ -440,6 +441,7 @@ fn main() { ) .pubsub_config(PubSubConfig { enable_vote_subscription, + enable_block_subscription, ..PubSubConfig::default() }) .rpc_port(rpc_port) diff --git a/validator/src/cli.rs b/validator/src/cli.rs index a7a12324a0..63eb203012 100644 --- a/validator/src/cli.rs +++ b/validator/src/cli.rs @@ -2147,6 +2147,12 @@ pub fn test_app<'a>(version: &'a str, default_args: &'a DefaultTestArgs) -> App< .takes_value(false) .help("Enable the unstable RPC PubSub `voteSubscribe` subscription"), ) + .arg( + Arg::with_name("rpc_pubsub_enable_block_subscription") + .long("rpc-pubsub-enable-block-subscription") + .takes_value(false) + .help("Enable the unstable RPC PubSub `blockSubscribe` subscription"), + ) .arg( Arg::with_name("bpf_program") .long("bpf-program")