2018-02-09 13:07
浏览 99


I have a bit of code that listen to twitter's live tweets containing a particular word (here "obama" for the example) and prints them using the anaconda package (https://github.com/ChimeraCoder/anaconda).

I want to be able to shut down the stream of tweets at a given moment when I call an other function. In order to do this, I tried to have a channel called "stop" that whenever it receive a value, the program stops listening to the stream.

I tried the following code to stop the stream after 10 seconds of execution :

    func main() {
            trackingArray := []string{ "obama"}


            api := anaconda.NewTwitterApi(accessToken, accessTokenSecret)

            stream := api.PublicStreamFilter(url.Values{
                        "track":    trackingArray,

            stop := make(chan int)

            for {
                select {
                    case v := <- stream.C :
                        tweet, ok := v.(anaconda.Tweet)
                        if !ok {
                            /* handle incorrect type */


                    case <- stop :


           go After(&stop)

    func After(stop *chan int){
        time.Sleep(time.Second * 10)
        *stop <- 1

This code doesn't work at all and the stream never stops...

My stop channel should be reusable as the goal behind this would be that it act as a on/off toggle to start/stop listening to twitter's stream.

It may be a newbie question but I thought I had understood how channels work and I'm kinda lost here... Thanks in advance for your time!

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 邀请回答

1条回答 默认 最新

  • dowjgrm6787
    dowjgrm6787 2018-02-09 13:22

    You are starting the gouroutine go After(&stop) after the for loop, which the goroutine needs to break. That results in the loop never get broken and the gouroutine never starts.

    To fix it, simply put go After(&stop) before the for loop.

    点赞 评论