Observable<T>.create

Observable<T>.createでは、指定された動作をするオブザーバブルを作成できる。
from, just, rangeより複雑な発行動作をさせたいという場合が一般的らしいので、大抵はこれを使うらしい。
Reactive ExtensionsのObservable.Createと同じ。
(1.2.7でdeprecated。ただし、2系からは再びこの形式で推奨らしい。)

Observable (RxJava Javadoc 1.3.8)

Observable.OnSubscribeのcallの中で1から3を発行して完了。

1
2
3
Completed!

となる。

Sample/rxjava/Observable_T/create/src/Observable_T at master · bg1bgst333/Sample · GitHub