android - rxandroid 要求在 ui 线程上运行，即使它已在 AndroidSchedulers.mainThread() 上订阅

Question

我写了一个订阅者，当谷歌地图的 OnCameraChangeListener 被触发时，它会被触发。

Observable.create(new Observable.OnSubscribe<LatLng>()
    {
        @Override
        public void call(Subscriber<? super LatLng> subscriber)
        {
            if (!subscriber.isUnsubscribed())
            {
                mMap.setOnCameraChangeListener(cameraPosition ->
                        subscriber.onNext(cameraPosition.target));
            }
        }
    }).subscribeOn(AndroidSchedulers.mainThread())
            .observeOn(AndroidSchedulers.mainThread())
            .onErrorResumeNext(Observable.<LatLng>empty())
            .debounce(1, TimeUnit.SECONDS)
            .subscribe(position -> {
                if (position.latitude != 0 && position.longitude != 0)
                {
                    updateLocationMarker(position);
                }
            });

我正在更新位置标记如下:

private void updateLocationMarker(LatLng center)
{
    locationMarkertext.setText("Lat:" + center.latitude + " Long:" + center.longitude);
    //locationMarkerLayout.setVisibility(View.VISIBLE);
}

即使我的代码说要在 AndroidSchedulers.mainThread() 上运行，我也会收到此错误:

Caused by: rx.exceptions.OnErrorNotImplementedException: Only the original thread that created a view hierarchy can touch its views.

谁能帮我理解我的方法有什么问题

Answer 1

debounce 运算符默认运行在计算调度程序上，它将传递流经的事件。您必须使用主线程调度程序对其进行参数化:

.debounce(1, TimeUnit.SECONDS, AndroidSchedulers.mainThread())

此外，根据您创建通知源的位置，您可能根本不需要 observeOn 和 subscribeOn。