return map.get(id).toObservable()
                .filter(Objects::nonNull)
                .switchIfEmpty(Observable.error(new MyException("Happens")))
                .toSingle();