From 690b9751c3300857eb60b07fb58ba816bce6881f Mon Sep 17 00:00:00 2001
From: Chris Davies <cgrdavies@gmail.com>
Date: Wed, 23 Jul 2025 15:24:13 -0400
Subject: [PATCH] Update yellowstone_grpc.rs

---
 src/streaming/yellowstone_grpc.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/streaming/yellowstone_grpc.rs b/src/streaming/yellowstone_grpc.rs
index 909aebc..860172a 100755
--- a/src/streaming/yellowstone_grpc.rs
+++ b/src/streaming/yellowstone_grpc.rs
@@ -168,6 +168,7 @@ impl YellowstoneGrpc {
         bot_wallet: Option<Pubkey>,
         account_include: Option<Vec<String>>,
         account_exclude: Option<Vec<String>>,
+        account_required: Option<Vec<String>>,
         callback: F,
     ) -> AnyResult<()>
     where
@@ -182,10 +183,12 @@ impl YellowstoneGrpc {
             .collect::<Vec<String>>();
         let mut account_include = account_include.unwrap_or_default();
         let account_exclude = account_exclude.unwrap_or_default();
+        let account_required = account_required.unwrap_or_default();
+        
         account_include.extend(protocol_accounts.clone());
 
         let transactions =
-            self.get_subscribe_request_filter(account_include, account_exclude, vec![]);
+            self.get_subscribe_request_filter(account_include, account_exclude, account_required);
 
         // 订阅事件
         let (mut subscribe_tx, mut stream) = self.subscribe_with_request(transactions).await?;