stream.go
changeset 119 712aa5780660
parent 118 fb9bb98a8d70
child 121 ebb86cbdd218
equal deleted inserted replaced
118:fb9bb98a8d70 119:712aa5780660
    29 type stanzaHandler struct {
    29 type stanzaHandler struct {
    30 	id string
    30 	id string
    31 	// Return true means pass this to the application
    31 	// Return true means pass this to the application
    32 	f func(Stanza) bool
    32 	f func(Stanza) bool
    33 }
    33 }
    34 
       
    35 // BUG(cjyar) Review all these *Client receiver methods. They should
       
    36 // probably either all be receivers, or none.
       
    37 
    34 
    38 func (cl *Client) readTransport(w io.WriteCloser) {
    35 func (cl *Client) readTransport(w io.WriteCloser) {
    39 	defer w.Close()
    36 	defer w.Close()
    40 	p := make([]byte, 1024)
    37 	p := make([]byte, 1024)
    41 	for {
    38 	for {