stream.go
changeset 57 e6cb3f049137
parent 51 1af366d10d32
child 59 be6815a9653a
equal deleted inserted replaced
56:74686b8c9146 57:e6cb3f049137
   307 				log.Println("Received nil filter")
   307 				log.Println("Received nil filter")
   308 				filterIn <- nil
   308 				filterIn <- nil
   309 				continue
   309 				continue
   310 			}
   310 			}
   311 			filterIn <- topFilter
   311 			filterIn <- topFilter
       
   312 			topFilter = newFilterOut
   312 
   313 
   313 		case data, ok := <-topFilter:
   314 		case data, ok := <-topFilter:
   314 			if !ok {
   315 			if !ok {
   315 				break
   316 				break
   316 			}
   317 			}
   591 	res := cl.Jid.Resource
   592 	res := cl.Jid.Resource
   592 	bindReq := &bindIq{}
   593 	bindReq := &bindIq{}
   593 	if res != "" {
   594 	if res != "" {
   594 		bindReq.Resource = &res
   595 		bindReq.Resource = &res
   595 	}
   596 	}
   596 	msg := &Iq{Type: "set", Id: <- cl.Id, Nested: &bindReq}
   597 	msg := &Iq{Type: "set", Id: <- Id, Nested: &bindReq}
   597 	f := func(st Stanza) bool {
   598 	f := func(st Stanza) bool {
   598 		if st.GetType() == "error" {
   599 		if st.GetType() == "error" {
   599 			log.Println("Resource binding failed")
   600 			log.Println("Resource binding failed")
   600 			return false
   601 			return false
   601 		}
   602 		}