diff options
Diffstat (limited to 'internal/processing/stream/stream.go')
-rw-r--r-- | internal/processing/stream/stream.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/internal/processing/stream/stream.go b/internal/processing/stream/stream.go index a10ab2474..f3a9e92f3 100644 --- a/internal/processing/stream/stream.go +++ b/internal/processing/stream/stream.go @@ -63,12 +63,15 @@ func (p *Processor) toAccount(payload string, event string, timelines []string, } for _, t := range timelines { - if s.Timeline == string(t) { + if _, found := s.Timelines[t]; found { s.Messages <- &stream.Message{ Stream: []string{string(t)}, Event: string(event), Payload: payload, } + // break out to the outer loop, to avoid sending duplicates + // of the same event to the same stream + break } } } |