service.getContactsTest(getAccessToken())
                .subscribeOn(Schedulers.newThread())
                //Проверяю какие данные пришли, если мне не подходят сровлю кастомный рантаймэкзепшн
                .doOnNext(new ValidateResponseOrThrow())
                //Учитывая что булкинсерт уже заимплеменчен, потому не юзаю флетмап и транзаакции, сразу в форе конверчу в нужные обжекты
                .map(baseResponse -> ModelConverter.convertContactList(baseResponse.getResponse().getContactList()))
                //и засовываю в бд
                .doOnNext(contacts -> DatabaseHelper.getInstance(getActivity()).saveContacts(contacts))
                .observeOn(AndroidSchedulers.mainThread())
                //вывожу ответ в юи, если ошибка юзаю кастомный парсер чтоб получить ошибку с экзепшена
                .subscribe(contacts -> ToastsUtil.shortToast(getActivity(), "Contacts updated"),
                        throwable -> ToastsUtil.shortToast(getActivity(), ExceptionParcer.parceException(throwable)));