使用 Rx 对 Bing 地图中的地址进行地理编码

Question

我正在学习如何使用我正在开发的 Silverlight 4 应用程序的 Rx 扩展。我创建了一个示例应用程序来确定该过程，但我无法让它返回任何内容。 这是主要代码：

    private IObservable<Location> GetGPSCoordinates(string Address1)
    {
        var gsc = new GeocodeServiceClient("BasicHttpBinding_IGeocodeService") as IGeocodeService;

        Location returnLocation = new Location();
        GeocodeResponse gcResp = new GeocodeResponse();

        GeocodeRequest gcr = new GeocodeRequest();
        gcr.Credentials = new Credentials();
        gcr.Credentials.ApplicationId = APP_ID2;
        gcr.Query = Address1;

        var myFunc = Observable.FromAsyncPattern<GeocodeRequest, GeocodeResponse>(gsc.BeginGeocode, gsc.EndGeocode);
        gcResp = myFunc(gcr) as GeocodeResponse;

        if (gcResp.Results.Count > 0 && gcResp.Results[0].Locations.Count > 0)
        {
            returnLocation = gcResp.Results[0].Locations[0];
        }
        return returnLocation as IObservable<Location>;
    }

gcResp 返回为 null。任何想法或建议将不胜感激。

Answer 1

您订阅的可观察源是异步的，因此您无法在订阅后立即访问结果。您需要访问订阅中的结果。

更好的是，根本不订阅，只需编写响应：

private IObservable<Location> GetGPSCoordinates(string Address1)
{
    IGeocodeService gsc = 
        new GeocodeServiceClient("BasicHttpBinding_IGeocodeService");

    Location returnLocation = new Location();
    GeocodeResponse gcResp  = new GeocodeResponse();

    GeocodeRequest gcr = new GeocodeRequest();
    gcr.Credentials = new Credentials();
    gcr.Credentials.ApplicationId = APP_ID2;
    gcr.Query = Address1;

    var factory = Observable.FromAsyncPattern<GeocodeRequest, GeocodeResponse>(
        gsc.BeginGeocode, gsc.EndGeocode);

    return factory(gcr)
        .Where(response => response.Results.Count > 0 && 
                           response.Results[0].Locations.Count > 0)
        .Select(response => response.Results[0].Locations[0]);
}

如果您只需要第一个有效值（地址的位置不太可能更改），则添加 .Take(1)在 Where 和 Select 之间。

编辑：如果您想专门处理未找到的地址，您可以返回结果并让使用者处理它，也可以返回异常并提供 OnError订阅时的处理程序。如果您考虑执行后者，则可以使用 SelectMany：

return factory(gcr)
    .SelectMany(response => (response.Results.Count > 0 && 
        response.Results[0].Locations.Count > 0)
        ? Observable.Return(response.Results[0].Locations[0])
        : Observable.Throw<Location>(new AddressNotFoundException())
    );

Answer 2

如果展开 myFunc 的类型，您会看到它是 Func>。

Func<GeocodeRequest, IObservable<GeocodeResponse>> myFunc =
    Observable.FromAsyncPattern<GeocodeRequest, GeocodeResponse>
        (gsc.BeginGeocode, gsc.EndGeocode);

因此，当您调用 myFunc(gcr) 时，您得到的是 IObservable，而不是 GeocodeResponse。您的代码 myFunc(gcr) as GeocodeResponse 返回 null，因为转换无效。

您需要做的是获取可观察值的最后一个值，或者只是进行订阅。调用 .Last() 将阻塞。如果您调用 .Subscribe(...) 您的响应将通过回调线程传递。

试试这个：

gcResp = myFunc(gcr).Last();

让我知道你进展如何。

Answer 3

理查德（和其他人），

所以我有返回位置的代码，并且有订阅的调用代码。这是（希望）最后一期。当我调用 GetGPSCooperatives 时，下一条语句将立即执行，而无需等待订阅完成。以下是按钮 OnClick 事件处理程序中的示例。

Location newLoc = new Location();

GetGPSCoordinates(this.Input.Text).ObserveOnDispatcher().Subscribe(x =>
            {
             if (x.Results.Count > 0 && x.Results[0].Locations.Count > 0)
                  {
                     newLoc = x.Results[0].Locations[0];
                     Output.Text = "Latitude: " + newLoc.Latitude.ToString() +
  ", Longtude: " + newLoc.Longitude.ToString();
                  }
             else
                  {
                    Output.Text = "Invalid address";
                  }
});
            Output.Text = " Outside of subscribe --- Latitude: " + newLoc.Latitude.ToString() +
  ", Longtude: " + newLoc.Longitude.ToString();

在订阅外部进行的 Output.Text 赋值在订阅完成之前执行并显示零，然后订阅内部的 1 显示新的位置信息。

此过程的目的是获取位置信息，然后将其保存在数据库记录中，并且我在 Foreach 循环中按顺序处理多个地址。我选择 Rx Extensions 作为解决方案，以避免异步回调作为编码陷阱的问题。但看来我已经把一个陷阱换成了另一个陷阱。

想法、评论、建议？