よく使うやつから絶対つかわねーだろみたいなやつ書きました。 たまーに見返して毎日をゆたかにしましょう。 もしよければこっちに基本的な使い方が書いてあるのでどうぞ 生成 create [ReactiveX - Create operator][create] 別ObservableのsubscribeによってObservalbeを生成するオペレーター。 意味が分かれば図の通りなんだけど意味わかんないと思うのでサンプルコードを。 ではどういったときに使うかというと非同期処理等でエラーハンドリングが必要な際に使います。 では具体例を。 Observable<String> observable = Observable.create( new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? su