Changeset 59 in code for trunk/downstream.go


Ignore:
Timestamp:
Feb 17, 2020, 3:09:35 PM (5 years ago)
Author:
contact
Message:

Document Ring

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/downstream.go

    r58 r59  
    288288                }
    289289
    290                 consumer, ch := uc.ring.Consumer(seqPtr)
     290                consumer, ch := uc.ring.NewConsumer(seqPtr)
    291291                go func() {
    292292                        for {
Note: See TracChangeset for help on using the changeset viewer.