// package w3:
func (c *Client) SubscribeCtx(ctx context.Context, s w3types.RPCSubscriber) (*rpc.ClientSubscription, error)
func (c *Client) Subscribe(s w3types.RPCSubscriber) (*rpc.ClientSubscription, error)

// package w3types:
type RPCSubscriber {
	CreateRequest() (namespace string, ch any, params []any, err error)
}

// package module/eth:
func NewHeads(ch chan<- *types.Header) w3types.RPCSubscriber
func PendingTransactions(ch chan<- *types.Transaction) w3types.RPCSubscriber
func NewLogs(ch chan<- *types.Log, q ethereum.FilterQuery) w3types.RPCSubscriber