equal
deleted
inserted
replaced
78 } |
78 } |
79 } |
79 } |
80 |
80 |
81 func readXml(r io.Reader, ch chan<- interface{}, |
81 func readXml(r io.Reader, ch chan<- interface{}, |
82 extStanza map[string]func(*xml.Name) interface{}) { |
82 extStanza map[string]func(*xml.Name) interface{}) { |
83 if _, ok := Debug.(*noLog) ; ok { |
83 if _, ok := Debug.(*noLog) ; !ok { |
84 pr, pw := io.Pipe() |
84 pr, pw := io.Pipe() |
85 go tee(r, pw, "S: ") |
85 go tee(r, pw, "S: ") |
86 r = pr |
86 r = pr |
87 } |
87 } |
88 defer close(ch) |
88 defer close(ch) |
192 |
192 |
193 return nil |
193 return nil |
194 } |
194 } |
195 |
195 |
196 func writeXml(w io.Writer, ch <-chan interface{}) { |
196 func writeXml(w io.Writer, ch <-chan interface{}) { |
197 if _, ok := Debug.(*noLog) ; ok { |
197 if _, ok := Debug.(*noLog) ; !ok { |
198 pr, pw := io.Pipe() |
198 pr, pw := io.Pipe() |
199 go tee(pr, w, "C: ") |
199 go tee(pr, w, "C: ") |
200 w = pw |
200 w = pw |
201 } |
201 } |
202 defer func(w io.Writer) { |
202 defer func(w io.Writer) { |