Apache HttpAsyncClient的可观察API

#Rxjava #异步编程指南 #Stream数据流处理模式 #Reactive编程指南

2015-09-11 banq

这是将Netflix开源Rxjava与Apache的Http异步客户端结合的开源库。

创建一个可观察的请求源：


ObservableHttp.createGet("http://www.wikipedia.com", httpClient).toObservable();
ObservableHttp.createRequest(HttpAsyncMethods.createGet("http://www.wikipedia.com"), httpClient).toObservable();

下面是一个完整的请求和分析响应的代码，从客户端向服务器发出一个请求，得到响应后，将响应的byte[]转为String数组。


ObservableHttp.createRequest(HttpAsyncMethods.createGet("http://www.wikipedia.com"), client)
        .toObservable()
        .flatMap({ ObservableHttpResponse response ->
                return response.getContent().map({ byte[] bb ->
                        return new String(bb);
                });
        })
        .toBlockingObservable()
        .forEach({ String resp -> 
                // this will be invoked once with the response
                println(resp);
        });

项目源码见：
ReactiveX/RxApacheHttp · GitHub