20171109
https://codezine.jp/article/detail/9570?p=3
///
compile 'io.reactivex:rxjava:1.1.9'
///
package jp.co.wata.myapplication;
import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;
import rx.Observable;
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
// あいさつの言葉を通知するObservableの生成
//justメソッドで生成されたObservableの場合、
// 各データを通知するたびに購読解除の確認をしていることです。
// justメソッドは引数に渡したデータを順に通知するObesrvableを生成するメソッドです。
Observable<String> observableGreeting =
Observable.just("Hello, World!", "こんにちは、世界!");
// Observableを購読し処理を開始する
observableGreeting.subscribe(
// Observableからのデータを受け取った際の処理
item -> {
// 実行しているThread名の取得
String threadName = Thread.currentThread().getName();
// Observableからのデータをそのまま標準出力する
System.out.println(threadName + ": " + item);
},
// Observableからエラーを通知された際の処理
error -> {
error.printStackTrace();
},
// Observableから完了を通知された際の処理
() -> {
// 実行しているThread名の取得
String threadName = Thread.currentThread().getName();
System.out.println(threadName + ": 完了しました");
});
}
}