如何中断(无限)流

Question

我正在使用ExTwitter库，希望能够偶尔杀死对流API的调用以更改参数。

我当前的代码看起来像这样:

for tweet <- ExTwitter.stream_filter(track: terms) do
    process_tweet tweet
end

我能做些什么来表明我不想要更多的消息吗?

Answer 1

你可以抛出一个异常并捕获它:

try do
  for tweet <- ExTwitter.stream_filter(track: terms) do
    process_tweet tweet
    if logic_to_determine_halt?, do: throw :halt
  end
catch 
  :halt -> #finished
end

Answer 2

感谢您的尝试。我可以确认克里斯说的方法有效。作为一种替代方法，我把一个试验作为API方法调用在下面(尽管我不确定如何正确地采取无限流)。

https://github.com/parroty/extwitter/issues/2