3

我从网上找到的代码改编了以下代码。工作正常,但没有连续运行并拉入新推文。我需要改变什么?帮助表示赞赏。

private static void Stream_FilteredStreamExample()
{
    SqlConnection conn = new SqlConnection(@"Data Source=********************");
    conn.Open();

    for (; ; )
    {
        try
        {
            var stream = Stream.CreateFilteredStream();
            //stream.AddLocation(Geo.GenerateLocation(-180, -90, 180, 90));
            stream.AddTweetLanguageFilter(Language.English);
            stream.AddTrack("#TubeStrike");

            var timer = Stopwatch.StartNew();

            stream.MatchingTweetReceived += (sender, args) =>
            {

                var tweet = args.Tweet;

                if (timer.ElapsedMilliseconds > 1000)
                {
                    Console.WriteLine("{0}, {1}", tweet.IdStr, tweet.Text);
                    timer.Restart();
                }
            };

            stream.StartStreamMatchingAllConditions();
        }
        catch (Exception ex)
        {
            Console.WriteLine("Exception: {0}", ex.Message);
        }
    }
}
4

1 回答 1

2

您想使用以下代码:

stream.StreamStopped += (sender, args) =>
{
     stream.StartStreamMatchingAllConditions();
};
于 2015-07-13T14:16:08.283 回答