eth/filters: simplify switches (#17267)

This commit is contained in:
Daniel Liu 2024-03-14 18:12:40 +08:00
parent 40ee6f87f0
commit 43f038dbac

View file

@ -338,8 +338,7 @@ func (es *EventSystem) broadcast(filters filterIndex, ev interface{}) {
} }
} }
case *event.TypeMuxEvent: case *event.TypeMuxEvent:
switch muxe := e.Data.(type) { if muxe, ok := e.Data.(core.PendingLogsEvent); ok {
case core.PendingLogsEvent:
for _, f := range filters[PendingLogsSubscription] { for _, f := range filters[PendingLogsSubscription] {
if e.Time.After(f.created) { if e.Time.After(f.created) {
if matchedLogs := filterLogs(muxe.Logs, nil, f.logsCrit.ToBlock, f.logsCrit.Addresses, f.logsCrit.Topics); len(matchedLogs) > 0 { if matchedLogs := filterLogs(muxe.Logs, nil, f.logsCrit.ToBlock, f.logsCrit.Addresses, f.logsCrit.Topics); len(matchedLogs) > 0 {