public static <T extends ApiResponse> Observable<T> CallToObservable(Call<T> originalCall) {
        return Observable.<T>create(subscriber -> {
            Call<T> call = originalCall.clone();
            CallArbiter<T> arbiter = new CallArbiter<>(call, subscriber);
            subscriber.add(arbiter);
            subscriber.setProducer(arbiter);
            Response<T> response;
            try {
                response = call.execute();
                if (!response.isSuccessful()) {
                    throw new HttpException(response);
                }
                T body = response.body();
                if (body != null) {
                    if (!body.isSuccess()) {
                        throw new ApiException(body.code, body.message);
                    }
                    arbiter.emitResponse(body);
                } else {
                    throw new Exception("NullResponse");
                }
            } catch (Exception e) {
                Exceptions.throwIfFatal(e);
                arbiter.emitError(e);
            }
        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
    }