diff options
| author | obscuren <geffobscura@gmail.com> | 2015-03-19 23:19:54 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2015-03-19 23:19:54 +0800 |
| commit | 14a2f42f3700640f191e0095b50a266d2a919b38 (patch) | |
| tree | e22528f68c7bdab57a8cdfbcddc29df06c15457a /event | |
| parent | b52807f0c0ff1b89cc1d7172ce1b768a34d02b00 (diff) | |
| download | dexon-14a2f42f3700640f191e0095b50a266d2a919b38.tar.gz dexon-14a2f42f3700640f191e0095b50a266d2a919b38.tar.zst dexon-14a2f42f3700640f191e0095b50a266d2a919b38.zip | |
fixed chain event. Closes #529
Diffstat (limited to 'event')
| -rw-r--r-- | event/filter/eth_filter.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/event/filter/eth_filter.go b/event/filter/eth_filter.go index 4ba66a7e0..cb75d7e1a 100644 --- a/event/filter/eth_filter.go +++ b/event/filter/eth_filter.go @@ -63,7 +63,7 @@ func (self *FilterManager) filterLoop() { // Subscribe to events events := self.eventMux.Subscribe( core.PendingBlockEvent{}, - //core.ChainEvent{}, + core.ChainEvent{}, state.Logs(nil)) out: @@ -77,7 +77,7 @@ out: self.filterMu.RLock() for _, filter := range self.filters { if filter.BlockCallback != nil { - filter.BlockCallback(event.Block) + filter.BlockCallback(event.Block, event.Logs) } } self.filterMu.RUnlock() @@ -86,7 +86,7 @@ out: self.filterMu.RLock() for _, filter := range self.filters { if filter.PendingCallback != nil { - filter.PendingCallback(event.Block) + filter.PendingCallback(event.Block, event.Logs) } } self.filterMu.RUnlock() |