go chan concurrent stream threads

chanstream.go

package main

import (
	"fmt"
	"time"
)

func main(){
	stream := make( chan int)
	go sendStream(stream)

	for c := range stream {
		fmt.Println
	}

}

func sendStream(ch chan int){
	for{
		ch <- 3

		time.Sleep(3*time.Second)
	}
}