安卓的RxJava没有Observable.create吗？

Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        // 执行一些耗时操作
        String result = performSomeTask();
        
        // 发射结果
        emitter.onNext(result);
        
        // 完成发射
        emitter.onComplete();
    }
})
.subscribe(new Observer<String>() {
    @Override
    public void onSubscribe(Disposable d) {
        // 订阅时的操作
    }

    @Override
    public void onNext(String result) {
        // 处理结果
    }

    @Override
    public void onError(Throwable e) {
        // 处理错误
    }

    @Override
    public void onComplete() {
        // 完成操作
    }
});