forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-24 13:46:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

accounts: simplify code with new api(SubscribeFilterLogs)

Browse source
This commit is contained in:
cuiweixie 2025-08-08 20:38:04 +08:00
parent c3ef6c77c2
commit ac580b3427
1 changed files with 1 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
accounts/abi/bind/v2/base.go
View file

@ -473,23 +473,11 @@ func (c *BoundContract) FilterLogs(opts *FilterOpts, name string, query ...[]any
if opts.End != nil { if opts.End != nil {
config.ToBlock = new(big.Int).SetUint64(*opts.End) config.ToBlock = new(big.Int).SetUint64(*opts.End)
} }
/* TODO(karalabe): Replace the rest of the method below with this when supported
sub, err := c.filterer.SubscribeFilterLogs(ensureContext(opts.Context), config, logs) sub, err := c.filterer.SubscribeFilterLogs(ensureContext(opts.Context), config, logs)
*/
buff, err := c.filterer.FilterLogs(ensureContext(opts.Context), config)
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
} }
sub := event.NewSubscription(func(quit <-chan struct{}) error {
for _, log := range buff {
select {
case logs <- log:
case <-quit:
return nil
}
}
return nil
})
return logs, sub, nil return logs, sub, nil
} }