import rx.Observable; public class HelloPrint { public static void main(String[] args) { Observable<String> o = Observable.just("Merhaba RxJava!"); o.subscribe(System.out::println); } }just ile basit bir Observable yaratılmıştır. Bu observable ile abone olunduğu an (subscribe çağrıldığı zaman) Merhaba RxJava yazısı ekranda gözükecektir.
import rx.Observable; public class HelloPrintArray { public static void main(String[] args) { String[] arrays={"Merhaba","Hi","Nehaber","WhatsUp"}; Observable<String> o = Observable.from(arrays); o.subscribe(System.out::println); } }Bu uygulama çalıştırıldığında arrays içindeki tüm mesajlar ekrana basılacaktır. subscribe ile abone olunduğunda dizideki tüm değerler için println işlemi çalışacaktır.
import rx.functions.Action1; public class HelloAction implements Action1<String>{ @Override public void call(String t) { System.out.println("bildirim geldi : "+t); } }Bu sınıfı kullanacak Observable yapalım :
import rx.Observable; public class HelloTest { public static void main(String[] args) { Observable<String> myObservable = Observable.just("Merhaba RxJava!"); myObservable.subscribe(new HelloAction()); } }subscribe metoduna action verilmiştir. Action verilir verilmez ekranda Merhaba RxJava basılacaktır.
import rx.Subscriber; public class MySubscriber extends Subscriber<String>{ @Override public void onCompleted() {} @Override public void onError(Throwable arg0) {} @Override public void onNext(String arg0) { System.out.println("Bildirim geldi : "+arg0); } }Bu sınıf bir Observable'a aşağıdaki gibi abone yapılır :
import rx.Observable; import rx.Subscriber; public class ObservableTest { public static void main(String[] args) { Observable.OnSubscribe<String> onSubscriber=new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> t) { t.onNext("Merhaba RxJava"); t.onCompleted(); } }; Observable<String> myObservable = Observable.create(onSubscriber); myObservable.subscribe(new MySubscriber()); } }onSubscriber ile abonelik olduğu zaman çalışacak kod bölümü yazılmıştır. subscribe metodu ile abone olunduğunda onSubscriber içindeki kod çalışır.