rxjava怎么创建Observable对象

在RxJava中，创建Observable对象通常使用Observable.create()方法或者使用一些工厂方法如Observable.just(), Observable.fromArray()等。以下是一些创建Observable对象的常见方式：

1. 使用Observable.create()方法：

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class Main {
    public static void main(String[] args) {
        Observable<String> observable = Observable.create(emitter -> {
            try {
                emitter.onNext("Hello RxJava");
                emitter.onComplete();
            } catch (Exception e) {
                emitter.onError(e);
            }
        });

        observable.subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                System.out.println("Subscribed");
            }

            @Override
            public void onNext(String s) {
                System.out.println("Received: " + s);
            }

            @Override
            public void onError(Throwable e) {
                System.out.println("Error: " + e.getMessage());
            }

            @Override
            public void onComplete() {
                System.out.println("Completed");
            }
        });
    }
}

2. 使用Observable.just()方法：

import io.reactivex.Observable;

public class Main {
    public static void main(String[] args) {
        Observable<String> observable = Observable.just("Hello RxJava");

        observable.subscribe(s -> System.out.println("Received: " + s));
    }
}

3. 使用Observable.fromArray()方法：

import io.reactivex.Observable;

public class Main {
    public static void main(String[] args) {
        Observable<String> observable = Observable.fromArray("Hello RxJava", "Welcome to the world of RxJava");

        observable.subscribe(s -> System.out.println("Received: " + s));
    }
}

这些只是创建Observable对象的一些基本方法。RxJava提供了许多其他操作符和方法来创建和处理Observable对象，以满足不同的需求。