RxJava/RxAndroid - 来自传感器的无限事件流

Question

我有一个应用程序可以监控传感器的事件、转换它们并需要向订阅者推送上游。

例如，使用android.location.LocationManager 进行位置更改。转换可能包括使用原始lat/long 和GeoCoder 来获取Address。

如何为我的显示器 (LocationListener) 和发布者建模？

class MyLocationListener implements LocationListener {
    void onLocationChanged(Location l) {
        //Get Address using GeoCoder
    }
}


class MetaAPI {
    Observable<Address> address() {
        return Observable.create({what}); //<-- What should I add here?
        //Need to glue MyLocationManager and MetaAPI
    }
}

//So that I can use like this -->
public AddressObservation {
    void monitor() {
        metaApi.address()
            .subscribe(...)
            ...;
    }
}

Answer 1

您可以为此目的使用Subject。这只是主要思想，没有任何设计考虑（根据您的情况调整）：

class MyLocationListener implements LocationListener {
    void onLocationChanged(Location l) {
        //Get Address using GeoCoder
        MetaAPI.subject.onNext(null /* actual address object */);
    }
}

class MetaAPI {

    static Subject<Address, Address> subject = PublishSubject.<Address>create().toSerialized();

    Observable<Address> address() {
        return subject;
    }
}