Using create method to create Observables and subscribe

createObservablesAndSubscribing.java

private void createObservablesAndSubscribing() {
        Observable observable = Observable.create(new ObservableOnSubscribe() {
            @Override
            public void subscribe(@NonNull ObservableEmitter emitter) {

                emitter.onNext("Emitting new Stuff !!");
                emitter.onComplete();
            }
        });

        observable.subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(@NonNull Disposable d) {

            }

            @Override
            public void onNext(String o) {

                Log.d("RxJava Create", o);
            }

            @Override
            public void onError(@NonNull Throwable e) {

            }

            @Override
            public void onComplete() {
                Log.d("RxJava Create","Observable consumed");

            }
        });
}