Aşağıdaki örnekte Action kullanılacaktır.
Basit bir Action1 sınıfı yapalım :
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.
