diff options
author | kiel barry <kiel.j.barry@gmail.com> | 2018-05-03 19:54:36 +0800 |
---|---|---|
committer | Péter Szilágyi <peterke@gmail.com> | 2018-05-03 19:54:36 +0800 |
commit | 60b433ab84589c2a33553575677bfa61ae3d1078 (patch) | |
tree | 3e39f8ec7161f09491eb23c361356eb0e2bb2ca8 | |
parent | fd3da7c69d234459e9fb436ea74a7ff73db42f06 (diff) | |
download | dexon-60b433ab84589c2a33553575677bfa61ae3d1078.tar dexon-60b433ab84589c2a33553575677bfa61ae3d1078.tar.gz dexon-60b433ab84589c2a33553575677bfa61ae3d1078.tar.bz2 dexon-60b433ab84589c2a33553575677bfa61ae3d1078.tar.lz dexon-60b433ab84589c2a33553575677bfa61ae3d1078.tar.xz dexon-60b433ab84589c2a33553575677bfa61ae3d1078.tar.zst dexon-60b433ab84589c2a33553575677bfa61ae3d1078.zip |
event: golint updates for this or self warning (#16631)
* event/*: golint updates for this or self warning
* event/*: golint updates for this or self warning, pr updated per feedback
-rw-r--r-- | event/filter/filter.go | 38 |
1 files changed, 19 insertions, 19 deletions
diff --git a/event/filter/filter.go b/event/filter/filter.go index b1fbf30ee..a6fe46d6a 100644 --- a/event/filter/filter.go +++ b/event/filter/filter.go @@ -45,37 +45,37 @@ func New() *Filters { } } -func (self *Filters) Start() { - go self.loop() +func (f *Filters) Start() { + go f.loop() } -func (self *Filters) Stop() { - close(self.quit) +func (f *Filters) Stop() { + close(f.quit) } -func (self *Filters) Notify(filter Filter, data interface{}) { - self.ch <- FilterEvent{filter, data} +func (f *Filters) Notify(filter Filter, data interface{}) { + f.ch <- FilterEvent{filter, data} } -func (self *Filters) Install(watcher Filter) int { - self.watchers[self.id] = watcher - self.id++ +func (f *Filters) Install(watcher Filter) int { + f.watchers[f.id] = watcher + f.id++ - return self.id - 1 + return f.id - 1 } -func (self *Filters) Uninstall(id int) { - delete(self.watchers, id) +func (f *Filters) Uninstall(id int) { + delete(f.watchers, id) } -func (self *Filters) loop() { +func (f *Filters) loop() { out: for { select { - case <-self.quit: + case <-f.quit: break out - case event := <-self.ch: - for _, watcher := range self.watchers { + case event := <-f.ch: + for _, watcher := range f.watchers { if reflect.TypeOf(watcher) == reflect.TypeOf(event.filter) { if watcher.Compare(event.filter) { watcher.Trigger(event.data) @@ -86,10 +86,10 @@ out: } } -func (self *Filters) Match(a, b Filter) bool { +func (f *Filters) Match(a, b Filter) bool { return reflect.TypeOf(a) == reflect.TypeOf(b) && a.Compare(b) } -func (self *Filters) Get(i int) Filter { - return self.watchers[i] +func (f *Filters) Get(i int) Filter { + return f.watchers[i] } |