channel-deadlock-fixed.go

channel-deadlock-fixed.go

func readAndSend() {
   
   c := make(chan User)
   go readFromCouchbase("123", c)

   for user := range c {
      sendToKafka(user)
   }
}

func readFromCouchbase(key string, c chan User) {

   time.Sleep(5 * time.Millisecond)
   fmt.Println("# read from Couchbase for key -> " + key)
   c <- User{Id: 123, Name: "Emre"}
   close(c)         // look here!!
}

func sendToKafka(user User) {

   fmt.Println("# sending to Kafka for username -> " + user.Name)
   time.Sleep(5 * time.Millisecond)
}