RIA 服务匹配请求的响应

发布于 2024-09-25 08:33:32 字数 351 浏览 10 评论 0 原文

我想知道是否有人可以就以下问题提供一些建议。我们目前正在开发基于 RIA .NET 服务的 Silverlight 4 应用程序。应用程序中的一个屏幕允许用户输入搜索字符串，2 秒不活动后，请求将提交到我们的域服务。这一切都可以通过 Rx 很好地处理。

现在，在原始搜索返回之前可以执行第二次搜索。第二个请求也有可能在第一个请求之前返回。

实际上，我只是想找出人们使用什么模式和方法来管理对正确请求的正确响应。

您是否在请求中使用某种操作标识符？您是否为每个请求创建域服务的新实例？是否可以将请求的已完成事件与监视 textchange 事件的 Rx 可观察对象联系起来？

任何引导都会有帮助，

戴夫

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

请叫√我孤独 2024-10-02 08:33:32

你应该很容易解决这个问题。

如果我假设您有一个可观察的字符串来启动搜索，并且您有一个域服务，在给定字符串时返回一个 Result 对象，那么这就是您需要的代码：

IObservable<string> searchText
    = ...;

Func<string, IObservable<Result>> searchRequest
    = Observable.FromAsyncPattern<string, Result>(
        search.BeginInvoke,
        search.EndInvoke);

IObservable<Result> results
    = (from st in searchText
       select searchRequest(st))
      .Switch();

神奇之处在于Switch 扩展方法，“切换”到从 IObservable> 返回的最新可观察值 - 是的，它是一个嵌套的可观察值。

当新的 searchText 传入时，查询将返回根据传入搜索文本创建的新 IObservable。然后，Switch 切换 results observable 以使用最新的 observable，并忽略任何先前创建的 observable。

因此，结果是仅观察最新的搜索结果，而忽略任何先前的结果。

希望这是有道理的。 :-)

It should be quite easy for you to solve this problem.

If I assume you have an observable of string that initiates the search and that you have a domain service that returns a Result object when given the string then this is the kind of code you need:

IObservable<string> searchText
    = ...;

Func<string, IObservable<Result>> searchRequest
    = Observable.FromAsyncPattern<string, Result>(
        search.BeginInvoke,
        search.EndInvoke);

IObservable<Result> results
    = (from st in searchText
       select searchRequest(st))
      .Switch();

The magic is in the Switch extension method which "switches" to the latest observable returned from the IObservable<IObservable<Result>> - yes, it is a nested observable.

When a new searchText comes in, the query returns a new IObservable<Result> created from the incoming search text. The Switch then switches the results observable to use this latest observable and just ignores any previously created observables.

So the result is that only the latest search results are observed and any previous results are ignored.

Hopefully that makes sense. :-)

回复收藏 0 原文