Channel Ownership

02-channels/05-channel-ownership/main.go

@@ -0,0 +1,33 @@
+package main
+
+import "fmt"
+
+func main() {
+ // Create channel owner goroutine which return channel and
+ // writes data into channel and
+ // closes the channel when done.
+
+ consumer := func(ch <-chan int) {
+ // read values from channel
+ for v := range ch {
+ fmt.Printf("Received: %d\n", v)
+ }
+ fmt.Println("Done receiving!")
+ }
+
+ owner := func() <-chan int {
+ ch := make(chan int)
+
+ go func() {
+ defer close(ch)
+ ch <- 1
+ ch <- 2
+ ch <- 3
+ }()
+
+ return ch
+ }
+
+ ch := owner()
+ consumer(ch)
+}