diff options
| author | Valery Piashchynski <[email protected]> | 2021-05-27 13:26:12 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-05-27 13:26:12 +0300 |
| commit | 0a9aea326045e56716f0736f7aa8520305362c51 (patch) | |
| tree | 532ca326690d81e97136248dd798d23a56843278 /plugins/redis | |
| parent | 57a30c2b49c36161b3af3e539a8618c2d39a5cc9 (diff) | |
- Move bst to the pkg folder
- Add comments
- Fix all golangci-lint warnings
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/redis')
| -rw-r--r-- | plugins/redis/fanin.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/plugins/redis/fanin.go b/plugins/redis/fanin.go index 29016720..8e924b2d 100644 --- a/plugins/redis/fanin.go +++ b/plugins/redis/fanin.go @@ -56,9 +56,9 @@ func (fi *FanIn) AddChannel(topics ...string) error { func (fi *FanIn) read() { for { select { - //here we receive message from us (which we sent before in Publish) - //it should be compatible with the websockets.Msg interface - //payload should be in the redis.message.payload field + // here we receive message from us (which we sent before in Publish) + // it should be compatible with the websockets.Msg interface + // payload should be in the redis.message.payload field case msg, ok := <-fi.pubsub.Channel(): // channel closed |