Streaming APIを実行する部分 | Codetter（こーどったー）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
/// <summary>
/// Streaming APIを呼び出します。
/// </summary>
/// <typeparam name="T">APIからの戻り値の型</typeparam>
/// <param name="apiMethod">呼び出すAPI</param>
/// <param name="token">OAuthトークン</param>
/// <returns>APIからのレスポンスをpush通知する<see cref="IObservable{T}"/></returns>
public static IObservable<T> CallApi<T>(this IStreamingApi<T> apiMethod, Token token)
{
    return Observable.Create<T>(observer =>
    {
        HttpWebRequest request = null;
        Scheduler.TaskPool.Schedule(() =>
        {
            try
            {
                request = RequestGenerator.GenerateTwitterApiRequest(
                    apiMethod.RequestUri,
                    HttpMethodType.GET,
                    token,
                    DefaultSetting.Proxy,
                    DefaultSetting.Timeout,
                    DefaultSetting.UserAgent,
                    null,
                    apiMethod.Parameters,
                    null,
                    null
                );
                using (var res = request.GetResponse())//あとでレスポンスも扱うかもしれないので一応定義
                using (var sr = new StreamReader(res.GetResponseStream()))
                {
                    while (!sr.EndOfStream)
                    {
                        var line = sr.ReadLine();
                        if (!string.IsNullOrWhiteSpace(line))
                            observer.OnNext(apiMethod.Parse(line));
                    }
                    observer.OnCompleted();
                }
            }
            catch (WebException ex)
            {
                if (ex.Status != WebExceptionStatus.RequestCanceled)
                {
                    observer.OnError(ex);
                }
            }
            catch (Exception ex)
            {
                observer.OnError(ex);
            }
        });
        return () =>
        {
            if (request != null)
                request.Abort();
        };
    });
}
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX