如何在没有subscribe()的情况下处理BlockingObservable中的错误？
在没有subscribe()的情况下处理BlockingObservable中的错误，可以通过以下方式进行处理：
- 使用try-catch块：在使用BlockingObservable的时候，可以将其包裹在try-catch块中，捕获可能发生的异常，并进行相应的处理。例如，可以打印错误日志、返回默认值或者抛出自定义异常等。
- 使用onErrorReturn()操作符：BlockingObservable提供了onErrorReturn()操作符，可以在发生错误时返回一个默认值或者处理结果。可以在创建BlockingObservable时使用该操作符，指定错误发生时的处理逻辑。
- 使用onErrorResumeNext()操作符：类似于onErrorReturn()操作符，onErrorResumeNext()操作符也可以在发生错误时进行处理。不同之处在于，onErrorResumeNext()操作符可以返回一个新的Observable，用于继续处理后续的数据流。
- 使用retry()操作符：如果希望在发生错误时进行重试，可以使用retry()操作符。该操作符可以指定重试的次数或者条件，当错误发生时，会重新订阅Observable进行重试。
- 使用doOnError()操作符：doOnError()操作符可以在发生错误时执行一些额外的操作，例如打印日志、发送通知等。可以在创建BlockingObservable时使用该操作符，指定错误发生时的额外操作。
需要注意的是，以上方法都需要在subscribe()之前进行设置，因为BlockingObservable是同步的，只有在调用subscribe()方法后才会开始执行。另外，具体的处理方式和操作符的使用可能会因具体的业务场景而有所不同，可以根据实际需求选择合适的处理方式。
相关·内容
在运行在tomcat中的java web应用程序中，我在服务器日志中得到以下错误：
2018-03-16 13:18:49,456 ERROR [Caesium-1-3] c.a.scheduler.core.JobLauncher Scheduled job with ID 'IndexingAnalyticsJob' failed
rx.exceptions.OnErrorNotImplementedException: java.net.ConnectException: Connection refused
at rx.observab
浏览 2提问于2018-03-16得票数 0
回答已采纳
3回答
我正在尝试实现使用列出运行在Azure订阅上的Server实例的代码。
我按照发布的示例编写了以下代码：
Azure azure = Azure.authenticate(credentials)).withDefaultSubscription();
SqlServers sqlServers = azure.sqlServers();
PagedList<SqlServer> list = sqlServers.list();
但最后一行将抛出具有以下堆栈跟踪的java.lang.NoSuchMethodError：
Exception in thread "main
浏览 0提问于2018-07-12得票数 1
回答已采纳
1回答
我有一些类的初始化时间很长，例如Api。我的经理类加载Api类异步，代码如下
class MyManager{
private Observable<Api> apiProvider
private Api mApi;
MyManager(Observable<Api> apiProvider){
this.apiProvider = apiProvider;
apiProvider.subscribe(api -> mApi = api);
}
}
但是客户端可以调用MyManager类的方法，这是创
浏览 2提问于2017-02-21得票数 1
回答已采纳
我在kubernete和docker中使用微服务，当Zuul (网关)转发请求数据到服务时，我得到了一个UnknownHostException，我不能通过pod名ping到服务容器(但当我使用docker swarm而不是Kubernetes时，我可以正常地通过主机名ping )
这是我的服务yaml文件
apiVersion: apps/v1beta1
kind: Deployment
metadata:
name: merchantservice
labels:
run: merchantservice
spec:
template:
metadata:
浏览 0提问于2019-05-28得票数 6
我们在Spring启动应用程序中使用Azure Key Vault Provider加密SQL Server DB列，一切工作正常。但是，我们看到记录了“连接泄漏”警告消息，如下所示：
2019-12-04 16:26:26.332 WARN 1 --- [ ConnectionPool] okhttp3.OkHttpClient : A connection to https://xxxxx.vault.azure.net/ was leaked. Did you forget to close a response body? java.lang
浏览 162提问于2020-02-13得票数 0
我很难使用BlockingObservable。我有一种情况，我需要回叫已完成，然后在它完成之后，我可以做一个修改API调用来获取数据。具体来说，我需要先初始化一个支付网关sdk，然后在它成功初始化之后，我将进行一个更新调用。以下是我到目前为止所拥有的：
Observable.fromCallable(new Callable<PaymentStrategy>() {
@Override
public PaymentStrategy call() throws Exception {
浏览 9提问于2017-07-29得票数 0
我正在使用MQTT.js订阅实时遥测数据。 client.on('connect', function () {
console.log('client connected');
client.subscribe('flespi/state/gw/devices/' + flespi_id + '/telemetry/position',
{ qos: 0 },
function (err, granted){
console.log(err.toString())
浏览 240提问于2020-09-17得票数 0
回答已采纳
我有一个表单，与一个按钮，将发送电子邮件使用表单的内容。我想使用switchmap，因为我想防止用户点击垃圾邮件并创建大量的HTTP请求，但我不知道如何做到这一点。
在使用switchmap之前：
this.customService.sendEmail(this.emailContents).subscribe(
data => { console.log("Success") }
)
正在尝试使用switchmap：
this.customService.sendEmail(this.emailContents).pipe(
switchMap(()
浏览 15提问于2019-11-15得票数 2
回答已采纳
2回答
我正在测试一个场景，其中我想发送一个事件，并观察使用者何时完成处理来继续这个流，即当我触发事件时，我需要阻塞这个主线程直到使用者处理结束，使用rxJava可观察，我没有成功地锁定主线程以等待可观察的结果。
我的制片人
@Service
public class Producer {
private MessageChannel output;
@Autowired
private Consumer consumer;
@Autowired
public Producer(Processor processor) {
this.out
浏览 1提问于2017-05-18得票数 1
回答已采纳
2回答
我发现自己正在处理以最新版本编写的主题代码，并搜索web，而且我发现大部分devs没有处理subscription错误。
我的问题是：什么时候必须处理订阅中的错误？
无错误处理：
this.myService.observable$.subscribe(
(data) => {
// do stuff with data
}
);
通过错误处理：
this.myService.observable$.subscribe(
(data) => {
// do stu
浏览 2提问于2017-06-22得票数 3
回答已采纳
如果我的models/db.py中有这样的东西
db.define_table('magazine', Field('name'), Field('description'))
db.define_table('subscribe', Field('subscriber', db.auth_user), Field('magazine', db.magazine))
在controller/default.py中
# subscribe callback from view
@auth.
浏览 1提问于2013-05-01得票数 0
回答已采纳
我的问题是subscribe错误，由于在rxJava ()方法调用中缺少onError处理程序，所以没有处理异常。什么是解决这个问题？
compositeDisposable.add(backendApi.createEphemeralKey(params)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe { response ->
try {
val rawKey
浏览 0提问于2020-03-02得票数 0
1回答
我正在尝试java中的spark应用程序，它需要连接到Azure密钥库，并在从blob存储读取并推送到SQL Server表后获取一些秘密和处理数据。这是我的pom： <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/m
浏览 23提问于2020-12-11得票数 1
我正在通过AWS Appsync进行graphql订阅，并将OpenID连接配置为身份验证方法。它适用于mutation和query，但不适用于subscription。 type Mutation {
requestTransaction(transaction: TransactionRequestInput!): TransactionRequestACK!
@aws_oidc
responseTransaction(transaction: TransactionResponseInput!): TransactionResponse!
浏览 20提问于2020-06-09得票数 2
1回答
我有如下方法。
this.service1.info
.subscribe(a => this.service2.getDetails(a.id)
.subscribe(b => {
this.doStuff(b);
})
);
最近，我注意到，我们将有相当多的步骤，逐步推动更多的细节给客户，所以我预计以下可怕的模式出现。
this.service1.info
.subscribe(a => this.service2.getDetails(a.id)
...
.subscribe(z => {
浏览 2提问于2019-12-22得票数 0
回答已采纳
4回答
当用户单击“订阅”按钮时，我希望将用户email保存到数据库中。但是当我输入电子邮件并点击订阅按钮时，它会传递一个空数组！
订阅表单代码：
<form id="cx-subscribe-user">
<input type="text" name="email" id="email" placeholder="Enter Your Email" />
<button type="submit" id="subscribe-button"&
浏览 2提问于2019-04-11得票数 2
回答已采纳
API
add(data) {
return this.httpClient.post<any>('/api/v3/templates', data);
}
Observable
this.templateService.add(obj)
.subscribe(
(response) => {
console.log(reposne)
},
(error) => {
console.log(error)
}
);
我的Post API返回一个错误消息作为响应，因为名称已经存在，但我无法在输出到控制台的error对象中获取该错误
T
浏览 0提问于2017-09-20得票数 4
假设我有以下内容
function getData() {
return this.http.get('data');
}
...
getData().subscribe({
complete: () => {
this.closeDialog();
});
}
没有测试，但我认为这应该有效。但是，this.http调用可能引发错误。可以按以下方式修正
getData().subscribe({
error: (err) => { this.showNotification(err) },
complete: () =
浏览 4提问于2022-09-07得票数 0
当我试图使用返回字符串的调用API时，会调用订阅方法的错误处理程序。
前端代码：
this.httpClient.get<string>(`${this.baseUrl}/account/getname`).subscribe(
(accountName)=> console.log(accountName),
() => console.log("Failure")
);
控制器中的后端代码：
[HttpGet]
public string GetName()
{
return &#
浏览 1提问于2019-03-06得票数 3
在下面的代码段中，会抛出一个异常，正如预期的那样：
@Test
public void testError()
{
Mono.error(new NullPointerException())
.subscribe();
}
但是，在下面的代码段中，不抛出任何异常：
@Test
public void testErrorWithDoOnSuccess()
{
Mono.error(new NullPointerException())
.doOnSuccess(aValue -> {})
.subscribe();
}
当我
浏览 0提问于2018-09-03得票数 0
回答已采纳
我得到了一个对搜索表单的错误响应，我想为用户显示这个错误的细节。
这是我在Devtools网络选项卡中获得的JSON代码响应：
{
"schemas":["urn:ietf:params:scim:api:messages:2.0:Error"],
"details":["Invalid query: prefixed wildcard must have at least 3 chars can not be used with field 'email'"],
"st
浏览 4提问于2022-07-07得票数 0
对不起，这个标题不好，我真的不知道该怎么说。
假设我在角组件中有一个服务调用，例如：
this.myService.postObject(object).subscribe((serverData) => {
console.log('Server Name:' + serverData.name)
});
当然，当MyService看起来像：
postObject(dataObject: MyObject) {
return this.http.post(`http://server/object`, dataObject);
}
但是，当我想对异步结果作出反应
浏览 1提问于2019-04-04得票数 0
回答已采纳
我不知道这是否只是风格问题。至少有两种处理异步操作的方法：
dispatch后订阅
// action is being dispatched and subscribed
this.store.dispatch(new LoadCustomer(customerId)).subscribe(); // <-- subscribe
在国家：
@Action(LoadCustomer)
loadCustomer(context: StateContext<CustomerStateModel>,
customerId: string) {
retu
浏览 1提问于2019-09-26得票数 0
回答已采纳
2回答
我正在努力解决RxJava2中正确的异常处理问题。我正在尝试刷新OkHttp3拦截器中的令牌，如下所示：
tokenRepository.refreshToken(authStateManager.current.refreshToken!!)
.doOnError {
Log.w(TAG, "Could not obtain new access token.")
authStateManager.signOut()
浏览 136提问于2018-04-11得票数 0
回答已采纳
1回答
我想使用使用的Pusher连接。我有一些基本功能正在运行，比如将其连接到数据服务并接收消息。但是，我很难实现其他特性，比如读取连接的状态。也许你可以帮我回答以下几个问题：
1)启动推送器并将其连接到服务(pusher.connect())时会发生什么？连接的推杆是否在一个单独的线程中运行？
2)我怎样才能得到我的推手连接的当前状态？
3)如果我的推动者正在更新其他服务并行使用的对象，这会不会造成问题？
4)如何处理错误/异常？到目前为止，我还没有收到任何错误，错误看起来是一个正常的异常，还是处理方式不同？
谢谢!
下面我复制了我的当前代码。请注意，底部的while-循环只用于测试，以便代码继续
浏览 0提问于2015-02-03得票数 1
回答已采纳
3回答
我们想用HTTPS来进行基于虚拟和丝带的微服务通信。服务基于spring引导，tomcat是正确设置的。这些实例通过在尤里卡上启用的HTTPS和securePort注册。然而，当我们通过假装调用另一个微服务时，底层的Ribbon就不会识别该协议并返回到HTTP。我可以通过向FeignClient注释添加协议来解决这个问题，如下所示：
@FeignClient("https://users")
但是看起来Zuul代理和Hystrix/涡轮机(它们内部也在使用Ribbon )似乎存在相同的HTTP回退问题。是否有任何方法集中配置Ribbon以使用HTTPS作为默认值，或者使
浏览 9提问于2015-06-03得票数 11
回答已采纳
我正在尝试恢复主流，就像java reactor core Java示例中的onErrorContinue一样。
Flux.range(1, 5)
.flatMap(n -> (n == 3) ? Mono.error(new Throwable("StoppedError")) : Mono.just(n))
.onErrorContinue((throwable, o) -> { System.out.println("error with " + o); })
.subscribe(System.out::println, Syst
浏览 3提问于2020-11-10得票数 0
2回答
带处理错误的角度订阅
、、、
现在我正在尝试Angular2 Http进程。
我知道下面的函数：
sendGet(url) {
return this._http.get(url)
.map(res => res.json());
}
test(url) {
this.sendGet(url)
.subscribe(
data => {
processing data...
},
error => {
processing error...
},
() => {
ot
浏览 7提问于2017-07-12得票数 0
回答已采纳
我的服务如下所示：
sortTraceGroups(): Observable<TraceGroup[]> {
const url = environment.servicesBaseUrl + 'api/trace/sort?sort=' + this.sortChosen;
return this.httpClient.post<TraceGroup[]>(url, this.traceGroups)
.pipe(catchError(this.handleError));
}
p
浏览 0提问于2018-07-07得票数 2
回答已采纳
我正在执行以下调用，以便仅在用户存在的情况下执行操作
private _userConnector: UserConnector,
....
this._userConnector.get(userId).subscribe(() => {
// conditional action
},
(error) => {
console.log('your handling goes here');
});
但是，如果userId不存在，错误功能区将显示在背面：
我深入研究了_user
浏览 6提问于2020-06-03得票数 0
回答已采纳
1回答
我正在使用SpringBoot开发带有微服务体系结构的Rest后端。我使用Eureka作为发现服务，Zuul作为API网关。在本地主机工作时，一切都很好。但是当我在云上部署服务时，zuul网关的行为并不像预期的那样。所有服务仍在尤里卡登记。请求来到api网关，而不是转发到所需的服务器端，而是卡在api网关上，并给出
com.netflix.zuul.exception.ZuulException: Filter threw Exception
at com.netflix.zuul.FilterProcessor.processZuulFilter(FilterProcessor.ja
浏览 0提问于2018-04-05得票数 1
回答已采纳
我对角是新手，我想知道如何编写一个通用的http调用，它将结果/错误返回给模块文件。
以下是我所写的一个服务功能：
login(username: string, password: string) {
const body = new HttpParams()
.set('email', username)
.set('password', password);
return this.http.post('http://192.168.31.73:8080/istar/rest/auth/login',
浏览 0提问于2018-01-07得票数 0
回答已采纳
2回答
将RxJs运算符问题考虑为
//emit (1,2,3)
const source = Rx.Observable.of(1,2,3);
//start with 0
const example = source.startWith(0);
//output: 0,1,2,3
const subscribe = example.subscribe(val => console.log(val));
现在，我希望startWith()是承诺的结果。
// - 1
var pr = new Promise((res, rej) => {
setTimeout(() => r
浏览 0提问于2019-06-24得票数 1
1回答
我有一个服务，它负责使用计时器每隔x秒执行一次httpClient.get。我需要这个计时器在服务启动时开始运行，因此 timer 是在服务构造函数中定义的。根据我的理解，订阅应该在计时器范围中注册，如下所示(如果没有必要，我不想更改它，除非它是不正确的)。
只要没有来自后端服务器的错误\ exception \error 500异常，所有系统都能正常工作。现在，我需要两件事：
每当后端服务器出现问题时，我都想使用catchError。
我希望观察者继续按照计时器的时间运行(直到下一个滴答)，即使有异常。当出现异常时，我的最终结果应该是到达组件中的popUpAlert --请参阅我的代
浏览 5提问于2020-08-23得票数 2
回答已采纳
我试图在react按钮上记录单击事件：
const InputBox = () => {
const clicky = fromEvent(
document.getElementById('clickMe'),
'click'
).subscribe(clickety => console.log({ clickety }));
return (
<button id="clickMe" type="button">
Click Me
</b
浏览 5提问于2019-10-14得票数 6
回答已采纳
1回答
假设我们有角2的应用。一些服务方法通过post()返回数据，在这里我们有catch()来捕获可能的错误。
在组件中，我们订阅了可观测数据：
.subscribe(
()=> {
// some code
}
)
让我们假设我试图从locaStorage或任何其他关键操作中获取一些数据。我可以在这样的方法中添加try/catch语句吗？还是有另一种正确的方法？
浏览 4提问于2016-12-09得票数 2
回答已采纳
我注意到，即使我没有在订阅回调中包含错误处理程序，我的错误仍然会被记录到控制台中。默认情况下，Angular似乎会将所有错误记录到控制台，这个假设对吗？
例如，如果我包含错误处理程序：
console.log("beep");
of(1,2,3,4).pipe(
mergeMap(data => {
if (data === 3) {
return throwError('Error Occurred for data: '+ 3);
}
return of(data);
})
浏览 10提问于2019-11-09得票数 0
我为下面的方法写了一个测试：
private _segmentationStatus$: Subject<string> = new Subject();
public readonly segmentationStatus: Observable<string> = this._segmentationStatus$.asObservable();
/**
* Get the status from the segmentation service.
*/
public getStatus() {
const segmentati
浏览 14提问于2020-03-10得票数 0
1回答
我有一个服务，它向服务器发送一个POST请求：
addPerson(person:PersonDTO) :Observable<any> {
return this.httpClient.post<any>(this.urlBase + 'Persons', person);
}
我在组件中订阅服务：
this.valueService.addPerson(person).subscribe((data) => {
this.responseCode = data.statusText;
console.log(this.respo
浏览 1提问于2021-12-29得票数 -3
回答已采纳
订阅中的错误回调没有通过map函数映射到JSON！为什么？
this.http.get("/something")
.map((response: any) => response.json())
.subscribe((response: any) => {
// response is body of request
}, (error: any) => {
// error must be mapped again
浏览 0提问于2016-02-19得票数 3
下面是我尝试将 (我维护的事件聚合器)移植到Windows运行时世界的一个接口：
public interface ISubscriber
{
IDisposable Subscribe<M>(Action<M> subscription);
#if WINRT
[Windows.Foundation.Metadata.DefaultOverload]
#endif
IDisposable Subscribe(object subscriber);
IObservable<M> Observe<M&
浏览 4提问于2012-09-04得票数 14
回答已采纳
这个异常最终没有被处理，在Crashlytics中被报告为非致命的，因此从雷达上掉下来的用户看到了一个空白页，这是不可取的，因为崩溃会更好，因为失败是首选的。
理想情况下，我希望onError使用者成为触发器，这是我处理错误的地方，例如显示每个流的错误UI
然而，
fun main() {
Single.just(listOf("efaewf"))
.subscribe({
println("result is ${it[1]}")
}, {
浏览 5提问于2021-04-07得票数 1
回答已采纳
最近，我发现projectreactor.io很好地支持Publisher：
Flux.create(fluxSink -> {
for (int i = 0; i < 10; i++)
fluxSink.next(i);
fluxSink.complete();
})
.map(...)
.subscribe(...);
对Proccessor有什么好的支持吗？--我指的是类似或模拟的东西：
XXX process = new XXX
浏览 10提问于2017-11-17得票数 3
回答已采纳
我使用concatMap操作符内部的复杂逻辑发送了一个表单。一切正常，但在我的subscribe方法中，我有额外的http请求，它触发2次而不是1次。我尝试使用takeLast操作符，但没有帮助。我只需要在concatMap中完成所有请求后才在subscribe方法中进行请求。例如，如果我有两个updateMember()事件，在每次请求之后，我都会从subscribe方法中调用函数。
makeRequest(value) {
const team = toFormData(this.form.controls.profile.value);
this.teamService
.
浏览 29提问于2020-06-03得票数 2
回答已采纳
NestJ建议使用从HttpModule导入的@nestjs/axios来执行对外部API的请求。据我所知，HttpService将反应转化为可观测的。但是，如果要从远程服务中获取数据并立即处理这些数据，则很难在服务中获取数据：
try {
const metaData = await this.httpService.get(tokenUri).pipe(
map((res) => res.data),
catchError((e) => {
throw new HttpException(e.statusText, e.status);
浏览 6提问于2022-04-10得票数 1
1回答
我希望在flatMap中有一个条件来检查第一个可观察到的返回的内容。如果没有满足条件，我想中断并导航到不同的页面。
this.service.getData(id)
.flatMap((data) => {
if (!data) {
return Observable.throw(new NoDataFoundError());
}
return Observable.forkJoin(
this.service.getData2(id2),
this.service.getData3(id3),
);
})
浏览 2提问于2017-12-02得票数 2
回答已采纳
1回答
Rx异常处理失败
、、、
我正在使用带有改进的RxJava进行API调用，
通过使用RxJava方法(如、flatMap、和map )，我正在进行API调用，并在后台线程上的房间数据库中执行DB操作。
如果没有错误，我的实现是完美和工作良好的，但是当我在执行DB操作时得到一个错误或任何异常时，Application会因为以下Rx错误而崩溃。
E/AndroidRuntime: FATAL EXCEPTION: RxCachedThreadScheduler-1
The exception was not handled due to missing onError handler in the subscribe()
浏览 0提问于2018-12-05得票数 0
回答已采纳
1回答
推送订阅错误不触发捕获
、、、、
如果我的推送注册失败，我正在尝试采取具体的行动。为了使订阅失败，我已经将<link>删除到manifest.json文件(我正在使用Chrome)。如预期的那样，我得到了以下错误：
Uncaught (in promise) DOMException: Registration failed - manifest empty or missing
但是，此错误来自于index.html:1而不是main.js，订阅代码位于其中：
function subscribe() {
navigator.serviceWorker.ready
.then(function(reg)
浏览 3提问于2016-10-12得票数 3
回答已采纳
3回答
NdJson数据样本：
{"type":"data","id":"xyz"}
{"type":"value","id":"xcf"}
....
....
下面是我的Retrofit和RxJava代码，它们可以很好地用limit=1 (即{"type":"data","id":"xyz"} )获取数据。
adapter.create(API.class).getData()
.subscr
浏览 0提问于2015-10-18得票数 2
回答已采纳
2回答
我有一个消息总线，一个类向消息总线订阅了许多方法，例如：
class BookingService(object):
def start(self):
self.msg_bus.login(self.user, self.password)
self.msg_bus.subscribe('/broadcast/aliveResponse', self.handleAliveResponse)
self.msg_bus.subscribe('/broadcast/musicInfoUpdated', self
浏览 3提问于2010-12-08得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
