# HG changeset patch # User Chris Jones # Date 1378696626 -3600 # Node ID c94a7ce0f4fbe96b9d61a75de51df9e76d86b224 # Parent f35f853a52b6ce951ea8561d4cafaa6398ce8d82 Start reading from the recv channel earlier. diff -r f35f853a52b6 -r c94a7ce0f4fb example/interact.go --- a/example/interact.go Mon Sep 09 04:16:16 2013 +0100 +++ b/example/interact.go Mon Sep 09 04:17:06 2013 +0100 @@ -52,6 +52,13 @@ } defer close(c.Send) + go func(ch <-chan xmpp.Stanza) { + for obj := range ch { + fmt.Printf("s: %v\n", obj) + } + fmt.Println("done reading") + }(c.Recv) + err = c.StartSession(&xmpp.Presence{}) if err != nil { log.Fatalf("StartSession: %v", err) @@ -63,13 +70,6 @@ fmt.Printf("%d: %v\n", i, entry) } - go func(ch <-chan xmpp.Stanza) { - for obj := range ch { - fmt.Printf("s: %v\n", obj) - } - fmt.Println("done reading") - }(c.Recv) - p := make([]byte, 1024) for { nr, _ := os.Stdin.Read(p)