OkHttp With RxAndroid and RxJava

Api.java

    public static Observable<Response> getData() {
        StrictMode.ThreadPolicy policy = new StrictMode.ThreadPolicy.Builder().permitAll().build();
        StrictMode.setThreadPolicy(policy);
        final OkHttpClient client = new OkHttpClient();

        final Request request = new Request.Builder()
                .url("https://github.com/ar-android/panfic/raw/master/Panfic/gen/com/ocit/data.json")
                .get()
                .addHeader("cache-control", "no-cache")
                .addHeader("postman-token", "ac8311d5-3876-ea1e-53d3-85f9e397ea21")
                .build();

        return Observable.create(new Observable.OnSubscribe<Response>() {
            @Override public void call(Subscriber<? super Response> subscriber) {
                try {
                    Response response = client.newCall(request).execute();
                    subscriber.onNext(response);
                    subscriber.onCompleted();
                } catch (IOException e) {
                    e.printStackTrace();
                    subscriber.onError(e);
                }
            }
        });
    }

It is helpful for me. thanks a lot.

You should call OnComplete() on finally block

try {
// Do stuff
} catch (IOException e){
// Do stuff
} finally {
subscriber.onCompleted();
}