Create Operator Rx

RxOperatorCreate.java

import io.reactivex.Observable;
import io.reactivex.ObservableOnSubscribe;

public class RxOperatorCreate {
    public static void main(String[] args) {
        Observable
                .create((ObservableOnSubscribe<String>) emitter -> {
                    emitter.onNext("Yudi Setiawan");
                    emitter.onComplete();
                })
                .subscribe(System.out::println);
    }
}