jjzjj

关于 c#:Subscription on observable 未达到 oncompleted

codeneng 2023-03-28 原文

Subscription on observable not reaching to oncompleted

我正在尝试为 wcf 调用创建一个可观察的package器，我创建如下。

方法是这样的，

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
private IObservable<List<string>> Search(string searchTerm)
    {
        return Observable.Create<List<string>>(o =>
        {
            var searchClient = new SearchServiceClient();
            var s = Observable
                .FromEventPattern<SearchCompletedEventArgs>(searchClient,"SearchCompleted");
            var subscription = s.Subscribe(
                r =>
                {
                    if (r.EventArgs.Error == null)
                        o.OnNext(r.EventArgs.Result);
                    else
                    {
                        o.OnError(r.EventArgs.Error);
                    }
                },
                    e =>
                    {
                        o.OnError(e);
                    },
                        () =>
                        {
                            o.OnCompleted();
                        });
            searchClient.SearchAsync(searchTerm);
            return subscription;
        });
    }

和方法调用是，

1
2
3
4
5
6
7
8
9
10
11
12
13
Search("reactive").Subscribe(
                   r =>
                   {
                       MessageBox.Show("Result");
                   },
                   e =>
                   {
                       MessageBox.Show(e.ToString());
                   },
                   () =>
                   {
                       MessageBox.Show("Completed");
                   });

但它永远不会到达已完成的块。你能建议我哪里出错了吗？

@26日编辑

感谢 Petar Vu??etin、Rarous 和 Lee Campbell。我已经测试了所有三个建议，并且都在工作。但我喜欢 Petar 对单行代码的处理方式。即使它似乎 Observable.FromAsyncPatterns 已被贬低。

@Rarous 是正确的。事件没有完成的概念，因此 FromEventPattern 永远不会完成(或错误)。我认为首选的方法是使用 Petar Vu??etin 指定的 Task.FromAsync.ToObservable，然后考虑 Rarous 指定的 FromAsyncPattern。如果您真的想这样做，您可以修改您的代码，使其看起来像这样。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
private IObservable<List<string>> Search(string searchTerm)
{
    return Observable.Create<List<string>>(o =>
    {
        var searchClient = new SearchServiceClient();
        var s = Observable
            .FromEventPattern<SearchCompletedEventArgs>(searchClient,"SearchCompleted");
        var subscription = s.Subscribe(
            r =>
            {
                if (r.EventArgs.Error == null)
                {
                    o.OnNext(r.EventArgs.Result);
                    o.OnCompleted();
                }
                else
                {
                    o.OnError(r.EventArgs.Error);
                }
            });
        searchClient.SearchAsync(searchTerm);
        return subscription;
    });
}

从事件创建的 Observable 永远不会运行到完成。正如 Petar 所提到的，您可以从异步模式创建 Observables。除了将 Task 转换为 Observable 之外，您还可以使用工厂方法：

1
2
3
4
5
IObservable<string[]> Search(string searchTerm)
{
    var searchClient = new Service1Client();
    return Observable.FromAsyncPatterns(searchClient.BeginGetData, searchClient.EndGetData)(searchTerm);
}

  • 我认为最新的位使 FromAsyncPatterns 过时了。
  • 我明白了，我仍然以 .net 4.0 为目标。

如果您可以为您的 WCF 客户端生成异步方法，您可以尝试这种方法。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
 static void Main(string[] args)
        {
            var searcher = Search("test").Subscribe(Console.WriteLine);
            Console.WriteLine("Done");
            Console.ReadLine();
        }


        private static  IObservable<string[]> Search(string searchTerm)
        {
            var searchClient = new Service1Client();

            return Task<string[]>.Factory.FromAsync(searchClient.BeginGetData, searchClient.EndGetData, searchTerm, null).ToObservable();
        }
c#Subscriptionspannbspclass.netsystem.reactivewcf

有关关于 c#:Subscription on observable 未达到 oncompleted的更多相关文章

  1. c# - 如何在 ruby​​ 中调用 C# dll？ - 2

    如何在ruby​​中调用C#dll？ 最佳答案 我能想到几种可能性:为您的DLL编写(或找人编写)一个COM包装器，如果它还没有，则使用Ruby的WIN32OLE库来调用它；看看RubyCLR,其中一位作者是JohnLam，他继续在Microsoft从事IronRuby方面的工作。(估计不会再维护了，可能不支持.Net2.0以上的版本)；正如其他地方已经提到的，看看使用IronRuby，如果这是您的技术选择。有一个主题是here.请注意，最后一篇文章实际上来自JohnLam(看起来像是2009年3月)，他似乎很自在地断言RubyCL

  2. C# 到 Ruby sha1 base64 编码 - 2

    我正在尝试在Ruby中复制Convert.ToBase64String()行为。这是我的C#代码:varsha1=newSHA1CryptoServiceProvider();varpasswordBytes=Encoding.UTF8.GetBytes("password");varpasswordHash=sha1.ComputeHash(passwordBytes);returnConvert.ToBase64String(passwordHash);//returns"W6ph5Mm5Pz8GgiULbPgzG37mj9g="当我在Ruby中尝试同样的事情时，我得到了相同sha

  3. 基于C#实现简易绘图工具【100010177】 - 2

    C#实现简易绘图工具一.引言实验目的:通过制作窗体应用程序(C#画图软件),熟悉基本的窗体设计过程以及控件设计,事件处理等,熟悉使用C#的winform窗体进行绘图的基本步骤,对于面向对象编程有更加深刻的体会.Tutorial任务设计一个具有基本功能的画图软件**·包括简单的新建文件,保存,重新绘图等功能**·实现一些基本图形的绘制,包括铅笔和基本形状等,学习橡皮工具的创建**·设计一个合理舒适的UI界面**注明:你可能需要先了解一些关于winform窗体应用程序绘图的基本知识,以及关于GDI+类和结构的知识二.实验环境Windows系统下的visualstudio2017C#窗体应用程序三.

  4. ruby-on-rails - 关于 Ruby 的一般问题 - 2

    我在我的rails应用程序中安装了来自github.com的acts_as_versioned插件，但有一段代码我不完全理解，我希望有人能帮我解决这个问题class_eval我知道block内的方法(或任何它是什么)被定义为类内的实例方法，但我在插件的任何地方都找不到定义为常量的CLASS_METHODS，而且我也不确定是什么here，并且有问题的代码从lib/acts_as_versioned.rb的第199行开始。如果有人愿意告诉我这里的内幕，我将不胜感激。谢谢-C 最佳答案 这是一个异端。http://en.wikipedia

  5. ruby - 我怎样才能更好地了解/了解更多关于 Ruby 的知识？ - 2

    按照目前的情况，这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持，但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开，visitthehelpcenter指导。关闭9年前。我最近开始学习Ruby，这是我的第一门编程语言。我对语法感到满意，并且我已经完成了许多只教授相同基础知识的教程。我已经写了一些小程序(包括我自己的数组排序方法，在有人告诉我谷歌“冒泡排序”之前我认为它非常聪明)，但我觉得我需要尝试更大更难的东西来理解更多关于Ruby.关于如何执行此操作的任何想法？

  6. ruby - 关于 Ruby 中 Dir[] 和 File.join() 的混淆 - 2

    我在Ruby中遇到了一个关于Dir[]和File.join()的简单程序，blobs_dir='/path/to/dir'Dir[File.join(blobs_dir,"**","*")].eachdo|file|FileUtils.rm_rf(file)ifFile.symlink?(file)我有两个困惑:首先，File.join(@blobs_dir,"**","*")中的第二个和第三个参数是什么意思？其次，Dir[]在Ruby中有什么用？我只知道它等价于Dir.glob()，但是，我对Dir.glob()确实不是很清楚。 最佳答案

  7. c# - C# 中的 Flatten Ruby 方法 - 2

    我如何做Ruby方法"Flatten"RubyMethod在C#中。此方法将锯齿状数组展平为一维数组。例如:s=[1,2,3]#=>[1,2,3]t=[4,5,6,[7,8]]#=>[4,5,6,[7,8]]a=[s,t,9,10]#=>[[1,2,3],[4,5,6,[7,8]],9,10]a.flatten#=>[1,2,3,4,5,6,7,8,9,10 最佳答案 递归解决方案:IEnumerableFlatten(IEnumerablearray){foreach(variteminarray){if(itemisIEnume

  8. ruby - 可以像在 C# 中使用#region 一样在 Ruby 中使用 begin/end 吗？ - 2

    我最近从C#转向了Ruby，我发现自己无法制作可折叠的标记代码区域。我只是想到做这种事情应该没问题:classExamplebegin#agroupofmethodsdefmethod1..enddefmethod2..endenddefmethod3..endend...但是这样做真的可以吗？method1和method2最终与method3是同一种东西吗？还是有一些我还没有见过的用于执行此操作的Ruby惯用语？ 最佳答案 正如其他人所说，这不会改变方法定义。但是，如果要标记方法组，为什么不使用Ruby语义来标记它们呢？您可以使用

  9. c# - Ruby 等效于 C# Linq 聚合方法 - 2

    什么是Linq聚合方法的ruby​​等价物。它的工作原理是这样的varfactorial=new[]{1,2,3,4,5}.Aggregate((acc,i)=>acc*i);每次将数组序列中的值传递给lambda时，变量acc都会累积。 最佳答案 这在数学以及几乎所有编程语言中通常称为折叠。它是更普遍的变形概念的一个实例。Ruby从Smalltalk中继承了这个特性的名称，它被称为inject:into:(像aCollectioninject:aStartValueinto:aBlock一样使用。)所以，在Ruby中，它称为inj

  10. elasticsearch源码关于TransportSearchAction【阶段三】 - 2

    1.回顾.TransportServicepublicclassTransportServiceextendsAbstractLifecycleComponentTransportService：方法：1publicfinalTextendsTransportResponse>voidsendRequest(finalTransport.Connectionconnection,finalStringaction,finalTransportRequestrequest,finalTransportRequestOptionsoptions,TransportResponseHandlerT>

随机推荐