Go read write channels

read_write.go

package main

import "fmt"

type Msg struct {
	text int
}

func write(c chan <- interface{}) {
	for i := 0; i < 7; i++ {
		fmt.Println("w ", i)
		c <- &Msg{i}
	}
	fmt.Println("close")
	close(c)
}

func read(c chan interface{}, q chan <- int) {
	for {
		select {
		case r, closed := <-c:
			defer func() {
				q <- 1
			}()
			fmt.Println(fmt.Sprintf("r[%d], %v", r, closed))
		}
	}

}

func main() {
	b := 1
	c := make(chan interface{}, b)
	q := make(chan int)
	go write(c)
	go read(c, q)
	<-q
}