SubscribeFilterLogs subscribes to the results of a streaming filter query.
(ctx context.Context, q cpchain.FilterQuery, ch chan<- types.Log)
| 464 | |
| 465 | // SubscribeFilterLogs subscribes to the results of a streaming filter query. |
| 466 | func (c *Client) SubscribeFilterLogs(ctx context.Context, q cpchain.FilterQuery, ch chan<- types.Log) (cpchain.Subscription, error) { |
| 467 | return c.c.EthSubscribe(ctx, ch, "logs", toFilterArg(q)) |
| 468 | } |
| 469 | |
| 470 | func toFilterArg(q cpchain.FilterQuery) interface{} { |
| 471 | arg := map[string]interface{}{ |
nothing calls this directly
no test coverage detected