Add support for subscribing to newPendingTransactionsComplete

joleeee · Apr 20, 2022 · 175762e · 175762e
1 parent 3bc8aac
commit 175762e
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/ethers-providers/src/lib.rs b/ethers-providers/src/lib.rs
@@ -617,6 +617,15 @@ pub trait Middleware: Sync + Send + Debug {
         self.inner().subscribe_pending_txs().await.map_err(FromErr::from)
     }
 
+    async fn subscribe_pending_txs_complete(
+        &self,
+    ) -> Result<SubscriptionStream<'_, Self::Provider, Transaction>, Self::Error>
+    where
+        <Self as Middleware>::Provider: PubsubClient,
+    {
+        self.inner().subscribe_pending_txs_complete().await.map_err(FromErr::from)
+    }
+
     async fn subscribe_logs<'a>(
         &'a self,
         filter: &Filter,

diff --git a/ethers-providers/src/provider.rs b/ethers-providers/src/provider.rs
@@ -1097,6 +1097,15 @@ impl<P: JsonRpcClient> Middleware for Provider<P> {
         self.subscribe(["newPendingTransactions"]).await
     }
 
+    async fn subscribe_pending_txs_complete(
+        &self,
+    ) -> Result<SubscriptionStream<'_, P, Transaction>, ProviderError>
+    where
+        P: PubsubClient,
+    {
+        self.subscribe(["newPendingTransactionsComplete"]).await
+    }
+
     async fn subscribe_logs<'a>(
         &'a self,
         filter: &Filter,