mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-23 21:26:42 +00:00
fix time out issue
This commit is contained in:
parent
ace2f955a7
commit
bf2de519c2
1 changed files with 16 additions and 2 deletions
|
|
@ -473,8 +473,22 @@ 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)
|
||||||
}
|
}
|
||||||
sub, err := c.filterer.SubscribeFilterLogs(ensureContext(opts.Context), config, logs)
|
buff, err := c.filterer.FilterLogs(ensureContext(opts.Context), config)
|
||||||
return logs, sub, err
|
if err != nil {
|
||||||
|
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
|
||||||
}
|
}
|
||||||
|
|
||||||
// WatchLogs filters subscribes to contract logs for future blocks, returning a
|
// WatchLogs filters subscribes to contract logs for future blocks, returning a
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue