java - 如何从头开始创建我自己的热门 Observable？

Question

如何从头开始创建我自己的热 Observable？

我想创建自己的函数，返回 observable，返回位置:

public static Observable<Location> locationObservable(Context context, String provider, long minTime, float minDistance) {

这是针对 Android 的。建议使用Observable.create()为此目的，但是 example shows just passing constant list of integers给每个订阅者，这并不热。

如果我在这里做其他事情，例如，记住订阅者列表，那么我将如何实现取消订阅和许多其他功能？

即完全不知道在里面做什么Observable.OnSubscribe<Integer>()实现？

Answer 1

通常要创建 hot observable，您会使用某种Subject:PublishSubject、BehaviorSubject 等

查看 BehaviorSubject 的示例 here .

class LocationService {
    private Subject<Location> subject = BehaviorSubject.create();

    Observable<Location> locationObservable(...) {
        return subject;
    }

    void onNewLocationListener(Location newLocation) {
        subject.onNext(newLocation);
    }
}