From 22bcd7809bdd342f7e1aa2ece59ce939d9a90db0 Mon Sep 17 00:00:00 2001 From: Edgar Aroutiounian Date: Tue, 1 Jun 2021 22:04:14 -0400 Subject: [PATCH] add subscription pending txn --- ethclient/ethclient.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/ethclient/ethclient.go b/ethclient/ethclient.go index a17696356c7c..a46ef51a49d5 100644 --- a/ethclient/ethclient.go +++ b/ethclient/ethclient.go @@ -462,7 +462,9 @@ func (ec *Client) PendingTransactionCount(ctx context.Context) (uint, error) { return uint(num), err } -// TODO: SubscribePendingTransactions (needs server side) +func (ec *Client) SubscribePendingTransactions(ctx context.Context, incoming chan common.Hash) (*rpc.ClientSubscription, error) { + return ec.c.EthSubscribe(ctx, incoming, "newPendingTransactions") +} // Contract Calling