安装包 io.realm.rx

类 RealmObservableFactory

java.lang.Object

io.realm.rx.RealmObservableFactory

所有已实现的接口：

RxObservableFactory

public class RealmObservableFactory
extends Object
implements RxObservableFactory

用于为 RxJava (<=2.0.*) 创建可观察对象的工厂类。

另请参阅：

() 、 RealmObject.asFlowable() 、 RealmResults.asFlowable() 、 DynamicRealm.asFlowable() 、 RealmObject.asFlowable()

构造函数摘要

构造函数

Constructor	说明
RealmObservableFactory(boolean emitFrozenObjects)	构造用于为 RxJava 创建 Realm 可观察量的工厂。

方法摘要

修饰符和类型	方法	说明
Observable<ObjectChange<DynamicRealmObject>>	changesetsFrom(DynamicRealm realm, DynamicRealmObject object)	为RealmObject创建一个 Observable。
<E> Observable<CollectionChange<RealmList<E>>>	changesetsFrom(DynamicRealm realm, RealmList<E> list)	为RealmList创建一个 Observable。
<E> Observable<CollectionChange<RealmResults<E>>>	changesetsFrom(DynamicRealm realm, RealmResults<E> results)	为RealmResults创建一个 Observable。
<E extends RealmModel> Observable<ObjectChange<E>>	changesetsFrom(Realm realm, E object)	为RealmObject创建一个 Observable。
<E> Observable<CollectionChange<RealmList<E>>>	changesetsFrom(Realm realm, RealmList<E> list)	为RealmList创建一个 Observable。
<E> Observable<CollectionChange<RealmResults<E>>>	changesetsFrom(Realm realm, RealmResults<E> results)	为RealmResults创建一个 Observable。
boolean	equals(Object o)
Flowable<DynamicRealm>	from(DynamicRealm realm)	为DynamicRealm创建 Flowable。
Flowable<DynamicRealmObject>	from(DynamicRealm realm, DynamicRealmObject object)	为DynamicRealmObject创建 Flowable。
<E> Flowable<RealmList<E>>	from(DynamicRealm realm, RealmList<E> list)	为RealmList创建 Flowable。
<E> Single<RealmQuery<E>>	from(DynamicRealm realm, RealmQuery<E> query)	从RealmQuery创建一个 Single。
<E> Flowable<RealmResults<E>>	from(DynamicRealm realm, RealmResults<E> results)	为RealmResults创建 Flowable。
Flowable<Realm>	from(Realm realm)	为Realm创建 Flowable。
<E extends RealmModel> Flowable<E>	from(Realm realm, E object)	为RealmObject创建 Flowable。
<E> Flowable<RealmList<E>>	from(Realm realm, RealmList<E> list)	为RealmList创建一个 Observable。
<E> Single<RealmQuery<E>>	from(Realm realm, RealmQuery<E> query)	从RealmQuery创建一个 Single。
<E> Flowable<RealmResults<E>>	from(Realm realm, RealmResults<E> results)	为RealmResults创建 Flowable。
int	hashCode()

从类 java.lang.继承的方法对象

getClass, notify, notifyAll, toString, wait, wait, wait

构造函数详细信息

RealmObservableFactory

public RealmObservableFactory(boolean emmitFrozenObjects)

构造用于为 RxJava 创建 Realm 可观察量的工厂。

参数：

emitFrozenObjects - true ，如果在返回给用户之前应冻结所有对象。 如果它们应该是活动对象，则为false 。

方法详细信息

from

public Flowable<Realm> from(Realm realm)

从接口复制的描述： RxObservableFactory

为Realm创建 Flowable。 订阅 Realm 时以及每次后续更新 Realm 时，它都应发出 Realm 的初始状态。

Realm Flowables 很热门，因为 Realm 会自动保持最新状态。

指定者：

from 在接口中 RxObservableFactory

参数：

realm - Realm监听更改。

返回：

向 Realm 发出所有更新的 Rx 可观察对象。

from

public Flowable<DynamicRealm> from(DynamicRealm realm)

从接口复制的描述： RxObservableFactory

为DynamicRealm创建 Flowable。 订阅 Realm 时以及每次后续更新 Realm 时，它都应发出 Realm 的初始状态。

DynamicRealm 可观察量很热门，因为 DynamicRealm 会自动保持最新状态。

指定者：

from 在接口中 RxObservableFactory

参数：

realm - DynamicRealm监听更改。

返回：

将所有更新发送到 DynamicRealm 的 Rx 可观察对象。

from

public <E> Flowable<RealmResults<E>> from(Realm realm,
                                          RealmResults<E> results)

从接口复制的描述： RxObservableFactory

为RealmResults创建 Flowable。 在订阅 RealmResults 时以及在每次后续更新 RealmResults 时，它都应发出初始 RealmResult。

RealmResults 可观察量很热，因为 RealmResults 会自动保持最新。

指定者：

from 在接口中 RxObservableFactory

类型参数：

E - RealmObject 的类型

参数：

realm - Realm实例结果来自。

results - RealmResults监听更改。

返回：

发出对 RealmObject 的所有更新的 Rx 可观察对象。

changesetsFrom

public <E> Observable<CollectionChange<RealmResults<E>>> changesetsFrom(Realm realm,
                                                                        RealmResults<E> results)

从接口复制的描述： RxObservableFactory

为RealmResults创建一个 Observable。 它应在订阅时发出初始 RealmResult，并在每次后续更新 RealmResults 时发出 RealmResults + 描述更新的OrderedCollectionChangeSet 。

变更集可观察量不支持背压，因为变更集取决于前一个变更集的状态。 因此，应将背压的处理留给用户。

指定者：

changesetsFrom 在接口中 RxObservableFactory

类型参数：

E - RealmObject 的类型

参数：

realm - Realm实例结果来自。

results - RealmResults监听更改。

返回：

发出所有更新及其变更集的 Rx 可观察量。

from

public <E> Flowable<RealmResults<E>> from(DynamicRealm realm,
                                          RealmResults<E> results)

从接口复制的描述： RxObservableFactory

为RealmResults创建 Flowable。 在订阅 RealmResults 时以及在每次后续更新 RealmResults 时，它都应发出初始 RealmResult。

Realm 可观察量很热门，因为 RealmResults 会自动保持最新。

指定者：

from 在接口中 RxObservableFactory

参数：

realm - DynamicRealm实例结果来自。

results - RealmResults监听更改。

返回：

将所有更新发送到 RealmResults 的 Rx 可观察对象。

changesetsFrom

public <E> Observable<CollectionChange<RealmResults<E>>> changesetsFrom(DynamicRealm realm,
                                                                        RealmResults<E> results)

从接口复制的描述： RxObservableFactory

为RealmResults创建一个 Observable。 它应在订阅时发出初始 RealmResult，并在每次后续更新 RealmResults 时发出 RealmResults + 描述更新的OrderedCollectionChangeSet 。

变更集可观察量不支持背压，因为变更集取决于前一个变更集的状态。 因此，应将背压的处理留给用户。

指定者：

changesetsFrom 在接口中 RxObservableFactory

参数：

realm - Realm实例结果来自。

results - RealmResults监听更改。

返回：

发出所有更新及其变更集的 Rx 可观察量。

from

public <E> Flowable<RealmList<E>> from(Realm realm,
                                       RealmList<E> list)

从接口复制的描述： RxObservableFactory

为RealmList创建一个 Observable。 在订阅 RealmList 以及后续每次更新 RealmList 时，它都应发出初始列表。

RealmList 可观察量很热门，因为 RealmList 会自动保持最新。

注意：RealmList 目前不支持RealmChangeListener 。

指定者：

from 在接口中 RxObservableFactory

类型参数：

E - 查询目标的类型

参数：

realm - Realm实例列表的来源。

list — 用于侦听变更的 RealmObject。

changesetsFrom

public <E> Observable<CollectionChange<RealmList<E>>> changesetsFrom(Realm realm,
                                                                     RealmList<E> list)

从接口复制的描述： RxObservableFactory

为RealmList创建一个 Observable。 它应在订阅时发出初始 RealmList，并在每次后续更新 RealmIst 时发出 RealmList + 描述更新的OrderedCollectionChangeSet 。

变更集可观察量不支持背压，因为变更集取决于前一个变更集的状态。 因此，应将背压的处理留给用户。

指定者：

changesetsFrom 在接口中 RxObservableFactory

类型参数：

E - RealmObject 的类型

参数：

realm - Realm实例列表的来源。

list - RealmList监听更改。

返回：

发出所有更新及其变更集的 Rx 可观察量。

from

public <E> Flowable<RealmList<E>> from(DynamicRealm realm,
                                       RealmList<E> list)

从接口复制的描述： RxObservableFactory

为RealmList创建 Flowable。 在订阅 RealmList 以及后续每次更新 RealmList 时，它都应发出初始列表。

RealmList 可观察量很热门，因为 RealmList 会自动保持最新。

注意：RealmList 目前不支持RealmChangeListener 。

指定者：

from 在接口中 RxObservableFactory

参数：

realm - DynamicRealm实例列表的来源。

list — 用于侦听变更的 RealmList。

changesetsFrom

public <E> Observable<CollectionChange<RealmList<E>>> changesetsFrom(DynamicRealm realm,
                                                                     RealmList<E> list)

从接口复制的描述： RxObservableFactory

为RealmList创建一个 Observable。 它应在订阅时发出初始 RealmList，并在每次后续更新 RealmList 时发出 RealmList + 描述更新的OrderedCollectionChangeSet 。

变更集可观察量不支持背压，因为变更集取决于前一个变更集的状态。 因此，应将背压的处理留给用户。

指定者：

changesetsFrom 在接口中 RxObservableFactory

参数：

realm - Realm实例列表的来源。

list - RealmList监听更改。

返回：

发出所有更新及其变更集的 Rx 可观察量。

from

public <E extends RealmModel> Flowable<E> from(Realm realm,
                                               E object)

从接口复制的描述： RxObservableFactory

为RealmObject创建 Flowable。 在订阅对象时以及每次后续更新对象时，它都应发出初始对象。

RealmObject 可观察量很热门，因为 RealmObject 会自动保持最新状态。

指定者：

from 在接口中 RxObservableFactory

类型参数：

E - 查询目标的类型

参数：

realm - Realm实例对象的来源。

object — 用于侦听变更的 RealmObject。

changesetsFrom

public <E extends RealmModel> Observable<ObjectChange<E>> changesetsFrom(Realm realm,
                                                                         E object)

从接口复制的描述： RxObservableFactory

为RealmObject创建一个 Observable。 它应在订阅时发出初始对象，并且在每次后续更新对象时，它应发出对象 + 描述更新的ObjectChangeSet 。

变更集可观察量不支持背压，因为变更集取决于前一个变更集的状态。 因此，应让用户自行处理背压。

指定者：

changesetsFrom 在接口中 RxObservableFactory

类型参数：

E - RealmObject 的类型

参数：

realm - Realm实例对象的来源。

object — 用于侦听变更的 RealmObject。

from

public Flowable<DynamicRealmObject> from(DynamicRealm realm,
                                         DynamicRealmObject object)

从接口复制的描述： RxObservableFactory

为DynamicRealmObject创建 Flowable。 在订阅对象时以及每次后续更新对象时，它都应发出初始对象。

DynamicRealmObject 可观察量很热门，因为 DynamicRealmObject 会自动保持最新状态。

指定者：

from 在接口中 RxObservableFactory

参数：

realm - DynamicRealm实例对象的来源。

object — 用于侦听变更的 DynamicRealmObject。

changesetsFrom

public Observable<ObjectChange<DynamicRealmObject>> changesetsFrom(DynamicRealm realm,
                                                                   DynamicRealmObject object)

从接口复制的描述： RxObservableFactory

为RealmObject创建一个 Observable。 它应在订阅时发出初始对象，并且在每次后续更新对象时，它应发出对象 + 描述更新的ObjectChangeSet 。

变更集可观察量不支持背压，因为变更集取决于前一个变更集的状态。 因此，应让用户自行处理背压。

指定者：

changesetsFrom 在接口中 RxObservableFactory

参数：

realm - Realm实例对象的来源。

object — 用于侦听变更的 RealmObject。

from

public <E> Single<RealmQuery<E>> from(Realm realm,
                                      RealmQuery<E> query)

从接口复制的描述： RxObservableFactory

从RealmQuery创建一个 Single。 它应该发出查询，然后完成。

RealmQuery 可观察到的数据是冷的。

指定者：

from 在接口中 RxObservableFactory

类型参数：

E - 查询目标的类型

参数：

realm - Realm实例查询来自。

query - 要发出的 RealmQuery。

from

public <E> Single<RealmQuery<E>> from(DynamicRealm realm,
                                      RealmQuery<E> query)

从接口复制的描述： RxObservableFactory

从RealmQuery创建一个 Single。 它应该发出查询，然后完成。

RealmQuery 可观察到的数据是冷的。

指定者：

from 在接口中 RxObservableFactory

参数：

realm - DynamicRealm实例查询来自。

query — 用于侦听变更的 RealmObject。

等于

公共布尔等于（ 对象 o）

覆盖：

equals 课堂上 Object

hashCode

public int hashCode()

覆盖：

hashCode 课堂上 Object