rx-java 你好,世界!

示例

以下将消息打印Hello, World!到控制台

public void hello() {
  Observable.just("Hello, World!") // 创建新的可观察的
    .subscribe(new Action1<String>() { // 订阅并执行动作

       @Override
       public void call(String st) {
         System.out.println(st);
       }

    });
}

或使用Java 8 Lambda表示法

public void hello() {
      Observable.just("Hello, World!") // 创建新的可观察的
        .subscribe(onNext -> { // 订阅并执行动作
             System.out.println(onNext);   
        });
}