MaybeObservable.java

        Maybe.create(new MaybeOnSubscribe<User>() {
            @Override
            public void subscribe(MaybeEmitter<User> emitter) {
                User user = new User("Anitaa");
                emitter.onSuccess(user);
            }
        })
                .observeOn(Schedulers.io())
                .subscribe(new MaybeObserver<User>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onSuccess(User user) {
                        System.out.println(String.format("User with name '%s' successfully created ", user.getName()));
                    }

                    @Override
                    public void onError(Throwable e) {
                        System.out.println("onError is called: " + e.getMessage());
                    }

                    @Override
                    public void onComplete() {
                        System.out.println("onComplete is called");
                    }
                });