Changeset 233 in code for trunk

Timestamp:

Apr 6, 2020, 4:34:33 PM (5 years ago)

Author:

contact

Message:

Simplify ring consumer loop

No need to use Peek here.

File:

• trunk/downstream.go (modified) (2 diffs)

trunk/downstream.go

@@ -694 +694 @@
 
                 for {
-                        msg := consumer.Peek()
+                        msg := consumer.Consume()
                         if msg == nil {
                                 break
@@ -700 +700 @@
 
                         dc.sendFromUpstream(msg, uc)
-                        consumer.Consume()
                 }
         })