Changeset 50 in code for trunk/downstream.go

Timestamp:

Feb 7, 2020, 3:43:54 PM (5 years ago)

Author:

contact

Message:

Add an in-memory ring buffer

References: ​https://todo.sr.ht/~emersion/jounce/2

File:

• trunk/downstream.go (modified) (1 diff)

trunk/downstream.go

@@ -232 +232 @@
                         }
                 }
+
+                consumer := uc.ring.Consumer()
+                for {
+                        msg := consumer.Consume()
+                        if msg == nil {
+                                break
+                        }
+                        c.messages <- msg
+                }
         })
+
         return nil
 }