|
|
|
@ -48,19 +48,19 @@ func getIQ(id string, c chan xmpp.IQ, iqc chan xmpp.IQ) {
|
|
|
|
|
func rcvStanzas(client *xmpp.Client, ctx context.Context, iqc chan xmpp.IQ, msgc chan xmpp.Chat) {
|
|
|
|
|
var received interface{}
|
|
|
|
|
var err error
|
|
|
|
|
for {
|
|
|
|
|
r := make(chan interface{})
|
|
|
|
|
e := make(chan error)
|
|
|
|
|
go func() {
|
|
|
|
|
for {
|
|
|
|
|
rcv, err := client.Recv()
|
|
|
|
|
if err != nil {
|
|
|
|
|
e <- err
|
|
|
|
|
} else {
|
|
|
|
|
r <- rcv
|
|
|
|
|
}
|
|
|
|
|
r := make(chan interface{})
|
|
|
|
|
e := make(chan error)
|
|
|
|
|
go func() {
|
|
|
|
|
for {
|
|
|
|
|
rcv, err := client.Recv()
|
|
|
|
|
if err != nil {
|
|
|
|
|
e <- err
|
|
|
|
|
} else {
|
|
|
|
|
r <- rcv
|
|
|
|
|
}
|
|
|
|
|
}()
|
|
|
|
|
}
|
|
|
|
|
}()
|
|
|
|
|
for {
|
|
|
|
|
select {
|
|
|
|
|
case <-ctx.Done():
|
|
|
|
|
return
|
|
|
|
|