streamer.go

package main

import (
	"fmt"
	"math/rand"
	"time"
)

func FeedStream(buf chan int, n int) {
	time.Sleep(1500 * time.Millisecond)
	for i:=0; i<n; i++ {
		buf <- rand.Intn(100)
	}
}

func main() {
	stream := make(chan int, 1000)

	go func(){for range time.Tick(1 * time.Second) {
		go FeedStream(stream, 100)
	}}()

	for n := range stream {
		fmt.Printf("Received %d\n", n)
	}
}