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