diff options
Diffstat (limited to 'eth/filters/filter_system.go')
| -rw-r--r-- | eth/filters/filter_system.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/eth/filters/filter_system.go b/eth/filters/filter_system.go index 4e999cda8..70139c1a9 100644 --- a/eth/filters/filter_system.go +++ b/eth/filters/filter_system.go @@ -338,8 +338,7 @@ func (es *EventSystem) broadcast(filters filterIndex, ev interface{}) { } } case *event.TypeMuxEvent: - switch muxe := e.Data.(type) { - case core.PendingLogsEvent: + if muxe, ok := e.Data.(core.PendingLogsEvent); ok { for _, f := range filters[PendingLogsSubscription] { if e.Time.After(f.created) { if matchedLogs := filterLogs(muxe.Logs, nil, f.logsCrit.ToBlock, f.logsCrit.Addresses, f.logsCrit.Topics); len(matchedLogs) > 0 { |