rxjava常用操作符

### RxJava常用操作符 #### 一、Observable的创建 RxJava的核心概念之一是`Observable`，它代表了数据源，能够发出数据项序列。在实际应用中，我们需要通过不同的方式来创建`Observable`，从而启动事件流。下面将详细介绍几种常见的创建方式。 ##### 1.1 `from()` `from()`函数可以将一个集合（如数组或可迭代对象）转换为一个`Observable`对象。这意味着可以从现有的集合数据结构中创建出一个新的`Observable`实例，并且该`Observable`会在订阅者订阅后按顺序发送集合中的每个元素。这对于处理序列数据非常有用。 **方法列表** - `public static <T> Observable<T> from(Future<? extends T> future)` - `public static <T> Observable<T> from(Future<? extends T> future, long timeout, TimeUnit unit)` - `public static <T> Observable<T> from(Future<? extends T> future, Scheduler scheduler)` - `public static <T> Observable<T> from(Iterable<? extends T> iterable)` - `public static <T> Observable<T> from(T[] array)` **示例代码** ```java // 使用数组创建Observable Observable<String> observable = Observable.from(new String[]{"hello", "hi"}); // 使用Future创建Observable FutureTask<String> futureTask = new FutureTask<>(new Callable<String>() { @Override public String call() throws Exception { // 异步操作 return "hihi"; } }); Scheduler.Worker worker = Schedulers.io().createWorker(); worker.schedule(new Action0() { @Override public void call() { futureTask.run(); } }); Observable<String> observable = Observable.from(futureTask); ``` **解析**：通过`from()`方法创建的`Observable`对象可以根据传入的不同类型的数据源来发送相应的数据。例如，如果传入的是一个`Future`对象，则会在该`Future`任务完成后发送结果；如果是传入一个数组或可迭代对象，则会依次发送其中的每个元素。 ##### 1.2 `just()` `just()`函数可以将一个或多个对象转换为一个`Observable`对象，并按顺序发射这些对象。这种方式非常适合用于创建简单的数据流，特别是当需要发送的数据量较少时。 **方法列表** - `public static <T> Observable<T> just(final T value)` - `public static <T> Observable<T> just(T t1, T t2)` - `public static <T> Observable<T> just(T t1, T t2, T t3)` - `...` - `public static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10)` **示例代码** ```java // 创建包含单个字符串的Observable Observable<String> observable = Observable.just("hello"); // 创建包含多个字符串的Observable Observable<String> observable = Observable.just("hello", "hi", ""); ``` **解析**：`just()`方法支持传递1到10个参数，当元素个数少于等于10时可以使用此方法。若超过10个，则建议使用`from()`方法。这是因为`just()`方法主要是为了简化小规模数据的创建过程而设计的。 ##### 1.3 `create()` `create()`函数允许开发者自定义一个`OnSubscribe`接口实现，通过这个接口可以在`Observable`被订阅时执行特定的操作。这为开发者提供了极大的灵活性，可以定制自己的数据发送逻辑。 **方法列表** - `public static <T> Observable<T> create(OnSubscribe<T> f)` **示例代码** ```java Observable.create(new OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { subscriber.onNext("Hello"); subscriber.onNext("World"); subscriber.onCompleted(); } }).subscribe(System.out::println); ``` **解析**：通过`create()`方法创建的`Observable`实例可以自定义发送数据的过程。上述示例中，我们在`call()`方法内定义了具体的发送逻辑，即发送两个字符串并完成整个流程。这种方式适用于更复杂的场景，比如根据某些条件动态决定发送哪些数据。 ### 总结 通过上述介绍可以看出，`from()`、`just()`和`create()`是创建`Observable`对象的主要方法。选择合适的方法取决于具体的应用场景和个人需求。例如，当数据来源于现有集合时，`from()`是最佳选择；对于少量固定的数据项，`just()`更为简便；而在需要高度定制化数据发送逻辑的情况下，`create()`则显得尤为重要。理解并灵活运用这些创建方法，可以帮助开发者更加高效地利用RxJava进行数据流处理和响应式编程。