LocationPresenter.java

public class LocationPresenter implements LocationContract.Presenter {

    private static final String TAG = "LOCATION";

    private final WeakReference<LocationContract.View> viewWeakReference;
    private final LocationInteractor interactor;
    private final CompositeDisposable disposables = new CompositeDisposable();

    @Inject
    public LocationPresenter(LocationContract.View view, LocationInteractor interactor) {
        this.viewWeakReference = new WeakReference<>(view);
        this.interactor = interactor;
    }

    @Override
    public void getLocation() {
        disposables.add(
            interactor.getLocation()
                .subscribe(
                    location -> {
                        LocationContract.View view = viewWeakReference.get();
                        if (view != null) {
                            view.showLatitude(String.valueOf(location.latitude()));
                            view.showLongitude(String.valueOf(location.longitude()));
                        }
                    },
                    throwable -> {
                        LocationContract.View view = viewWeakReference.get();
                        if (view != null) {
                            Log.e(TAG, "Error while getting location", throwable);
                            if (throwable instanceof NoLocationAvailableException) {
                                view.showNoLocationAvailable();
                            } else {
                                view.showGenericError();
                            }
                        }
                    }
                )
        );
    }

    @Override
    public void cleanup() {
        disposables.clear();
    }
}