SubscribeToMessageStream need help to understand

[tbellembois]

Hi,

I try to develop a real time light bot for Rocket. My bot subscribe to each direct room (ie. conversation with other users) with a common channel.

    if channels, e = c.GetChannelsIn(); e != nil {
        log.Panic("can not get channels in " + e.Error())
    }

    msgChannel := make(chan models.Message, 10)
    for _, ch := range channels {
        fmt.Println(fmt.Printf("subscribed to: %v", ch.ID))
        if e = c.SubscribeToMessageStream(&models.Channel{ID: ch.ID}, msgChannel); e != nil {
            log.Println("can not subscribe to message stream for channel " + ch.ID + " " + e.Error())
        }
    }

    count := 0
    for {
        fmt.Println(count)
        select {
        case m := <-msgChannel:
            fmt.Println(fmt.Sprintf("ID: %s RoomID: %s Msg: %s User: %v", m.ID, m.RoomID, m.Msg, m.User))
            count++
        }
    }

When I send a direct message to the bot on the Rocket Chat application the for loop prints exactly [number of subscribed channels] times the log message. It can not figure out why. I just wanted to wait for messages in the channel and reply to the sender.

Thanks for your help.

[tbellembois]

Did not see pull request #21 sorry. This fixes my issue.