# 創建操作 ## Create 使用一個函數從頭開始創建一個Observable  你可以使用`Create `操作符從頭開始創建一個Observable，給這個操作符傳遞一個接受觀察者作為參數的函數，編寫這個函數讓它的行為表現為一個Observable--恰當的調用觀察者的onNext，onError和onCompleted方法。 一個形式正確的有限Observable必須嘗試調用觀察者的onCompleted正好一次或者它的onError正好一次，而且此后不能再調用觀察者的任何其它方法。  RxJava將這個操作符實現為 `create` 方法。 建議你在傳遞給`create`方法的函數中檢查觀察者的`isUnsubscribed`狀態，以便在沒有觀察者的時候，讓你的Observable停止發射數據或者做昂貴的運算。 示例代碼： ```java Observable.create(new Observable.OnSubscribe<Integer>() { @Override public void call(Subscriber<? super Integer> observer) { try { if (!observer.isUnsubscribed()) { for (int i = 1; i < 5; i++) { observer.onNext(i); } observer.onCompleted(); } } catch (Exception e) { observer.onError(e); } } } ).subscribe(new Subscriber<Integer>() { @Override public void onNext(Integer item) { System.out.println("Next: " + item); } @Override public void onError(Throwable error) { System.err.println("Error: " + error.getMessage()); } @Override public void onCompleted() { System.out.println("Sequence complete."); } }); ``` 輸出： ``` Next: 1 Next: 2 Next: 3 Next: 4 Sequence complete. ``` `create`方法默認不在任何特定的調度器上執行。 * Javadoc: [`create(OnSubscribe)`](http://reactivex.io/RxJava/javadoc/rx/Observable.html#create(rx.Observable.OnSubscribe))