@@ -0,0 +1,1620 @@
+/*%0A * Copyright (c) 2016 Qiscus.%0A *%0A * Licensed under the Apache License, Version 2.0 (the %22License%22);%0A * you may not use this file except in compliance with the License.%0A * You may obtain a copy of the License at%0A *%0A *    http://www.apache.org/licenses/LICENSE-2.0%0A *%0A * Unless required by applicable law or agreed to in writing, software%0A * distributed under the License is distributed on an %22AS IS%22 BASIS,%0A * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.%0A * See the License for the specific language governing permissions and%0A * limitations under the License.%0A */%0A%0Apackage com.qiscus.sdk.util;%0A%0Aimport rx.Observable;%0Aimport rx.Scheduler;%0Aimport rx.Subscription;%0Aimport rx.android.schedulers.AndroidSchedulers;%0Aimport rx.schedulers.Schedulers;%0A%0A/**%0A * Created on : September 06, 2017%0A * Author     : zetbaitsu%0A * Name       : Zetra%0A * GitHub     : https://github.com/zetbaitsu%0A */%0Apublic class QiscusRxExecutor %7B%0A%0A    public static %3CT%3E Subscription execute(Observable%3CT%3E observable, Listener%3CT%3E listener) %7B%0A        return execute(observable, Schedulers.io(), AndroidSchedulers.mainThread(), listener);%0A    %7D%0A%0A    public static %3CT%3E Subscription execute(Observable%3CT%3E observable, Scheduler subscribeOn,%0A                                           Scheduler observeOn, Listener%3CT%3E listener) %7B%0A        return observable%0A                .subscribeOn(subscribeOn)%0A                .observeOn(observeOn)%0A                .subscribe(listener::onSuccess, listener::onError);%0A    %7D%0A%0A    public interface Listener%3CT%3E %7B%0A        void onSuccess(T result);%0A%0A        void onError(Throwable throwable);%0A    %7D%0A%7D%0A

Add rx executor