Tester program for a channel and a cosumer

test_channel_load.go

package main

import (
    "fmt"
    "time"

    "github.com/satori/go.uuid"
)

func infiniteUuid(prov chan uuid.UUID) {
    for {
        newg := uuid.NewV4()
        prov <- newg
    }
}

func main() {
    prov := make(chan uuid.UUID)

    go infiniteUuid(prov)

    for {
        
        count := 0
        var data uuid.UUID
        afterSec := time.After(time.Second)

        for cont := true; cont; {
            select {
            case data = <-prov:
                count++
            case <-afterSec:
                fmt.Printf("%d msg/s %s was last\n", count, data)
                cont = false
            }
        }
    }
}