From 698706b41f75569387a8a77324d22989b55dcc44 Mon Sep 17 00:00:00 2001 From: postmannen Date: Thu, 20 Jan 2022 07:50:58 +0100 Subject: [PATCH] update comments --- server.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/server.go b/server.go index 338d340..030a169 100644 --- a/server.go +++ b/server.go @@ -387,6 +387,9 @@ func (s *server) routeMessagesToProcess(dbFileName string) { // Start reading new fresh messages received on the incomming message // pipe/file requested, and fill them into the buffer. + // Since the new messages comming into the system is a []subjectAndMessage + // we loop here, unfold the slice, and put single subjectAndMessages's on + // the channel to the ringbuffer. go func() { for sams := range s.newMessagesCh { for _, sam := range sams {