本文介绍了如何在Rx OnNext处理程序中抛出错误的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

如果存在某种情况,我想在我的OnNext处理程序中生成错误,类似于:

I want to generate an error in my OnNext handler if a certain condition exists, similar to this:

 

 

private void multipleLongRunningProcessBtn_Click(object sender, EventArgs e)
{
//create a cold stream of values to process
var lst = new List<string>();
        lst.Add("http://www.reddit.com/");
        lst.Add("http://www.yahoo.com/");
        lst.Add("http://www.hello-online.org/");

        lst.ToObservable().ObserveOn(listBox1).Subscribe(
url => ProcessUrl(url),
err => PostMessage("OnError"),
() => PostMessage("Complete"));
}

public void ProcessUrl(string pUrl)
{
if (pUrl.Contains("hello-online")) throw new Exception("Bad URL");
Thread.Sleep(3000); //do lengthy work here


}




How do I properly generate the error?  The exception is causing the app to crash.



 

推荐答案

您需要做类似的事情;

You would need to do something like this;


public void ProcessUrl(string pUrl)
{
	try
	{
		if (pUrl.Contains("hello-online"))
			throw new Exception("Bad URL");
		Thread.Sleep(3000); //do lengthy work here 
	}
	catch(Exception ex)
	{
		ProcessError(ex);
	}
}


这篇关于如何在Rx OnNext处理程序中抛出错误的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

09-09 11:14